Enum actix_redis::RespError
[−]
[src]
pub enum RespError {
Internal(String),
IO(Error),
RESP(String, Option<RespValue>),
Remote(String),
Unexpected(Box<Error + 'static>),
}Variants
Internal(String)A non-specific internal error that prevented an operation from completing
IO(Error)An IO error occurred
RESP(String, Option<RespValue>)A RESP parsing/serialising error occurred
Remote(String)A remote error
Unexpected(Box<Error + 'static>)An unexpected error, boxed to allow type-erasure. In this context "unexpected" means "unexpected because we check ahead of time", it used to maintain the type signature of chains of futures; but it occurring at runtime should be considered a catastrophic failure.
Trait Implementations
impl Display for Error[src]
fn fmt(&self, f: &mut Formatter) -> Result<(), Error>[src]
Formats the value using the given formatter. Read more
impl Error for Error[src]
fn description(&self) -> &str[src]
A short description of the error. Read more
fn cause(&self) -> Option<&Error>[src]
The lower-level cause of this error, if any. Read more
impl From<Canceled> for Error[src]
impl<T> From<SendError<T>> for Error where
T: 'static, [src]
T: 'static,
impl From<Error> for Error[src]
impl Debug for Error[src]
fn fmt(&self, __arg_0: &mut Formatter) -> Result<(), Error>[src]
Formats the value using the given formatter. Read more
impl StreamHandler<RespValue, RespError> for RedisActor[src]
fn error(&mut self, err: RespError, _: &mut Self::Context) -> Running[src]
Method is called when stream emits error. Read more
fn handle(&mut self, msg: RespValue, _: &mut Self::Context)[src]
Method is called for every message received by this Actor
fn started(&mut self, ctx: &mut Self::Context)[src]
Method is called when stream get polled first time.
fn finished(&mut self, ctx: &mut Self::Context)[src]
Method is called when stream finishes. Read more
fn add_stream<S>(fut: S, ctx: &mut Self::Context) -> SpawnHandle where
E: 'static,
I: 'static,
S: Stream<Item = I, Error = E> + 'static,
Self::Context: AsyncContext<Self>, [src]
E: 'static,
I: 'static,
S: Stream<Item = I, Error = E> + 'static,
Self::Context: AsyncContext<Self>,
This method register stream to an actor context and allows to handle Stream in similar way as normal actor messages. Read more