risingwave_stream::error

Trait IntoUnexpectedExit

source
pub trait IntoUnexpectedExit {
    type Ret;

    // Required methods
    fn into_unexpected_exit(self, actor_id: impl Into<ActorId>) -> Self::Ret;
    fn into_unexpected_exit_with<__F, __ACTOR_ID>(self, f: __F) -> Self::Ret
       where __F: FnOnce() -> __ACTOR_ID,
             __ACTOR_ID: Into<ActorId>;
}
Expand description

Extension trait for converting StreamError into ErrorKind::UnexpectedExit with the given context.

Required Associated Types§

Required Methods§

source

fn into_unexpected_exit(self, actor_id: impl Into<ActorId>) -> Self::Ret

Converts StreamError into ErrorKind::UnexpectedExit with the given context.

source

fn into_unexpected_exit_with<__F, __ACTOR_ID>(self, f: __F) -> Self::Ret
where __F: FnOnce() -> __ACTOR_ID, __ACTOR_ID: Into<ActorId>,

Converts StreamError into ErrorKind::UnexpectedExit with the context returned by the given function.

Object Safety§

This trait is not object safe.

Implementations on Foreign Types§

source§

impl<__T> IntoUnexpectedExit for Result<__T, StreamError>

source§

fn into_unexpected_exit(self, actor_id: impl Into<ActorId>) -> Self::Ret

Converts StreamError into ErrorKind::UnexpectedExit with the given context.

source§

fn into_unexpected_exit_with<__F, __ACTOR_ID>(self, f: __F) -> Self::Ret
where __F: FnOnce() -> __ACTOR_ID, __ACTOR_ID: Into<ActorId>,

Converts StreamError into ErrorKind::UnexpectedExit with the context returned by the given function.

source§

type Ret = Result<__T, StreamError>

Implementors§