Enum actix_redis::RespError [−][src]
pub enum RespError { Internal(String), IO(Error), RESP(String, Option<RespValue>), Remote(String), EndOfStream, Unexpected(String), }
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
EndOfStream
End of stream - a connection is broken, or could not be established in the first place
Unexpected(String)
An unexpected error. 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.
If any error is propagated this way that needs to be handled, then it should be made into a proper option.
Trait Implementations
impl Error for Error
[src]
impl Error for Error
fn description(&self) -> &str
[src]
fn description(&self) -> &str
This method is soft-deprecated. Read more
fn cause(&self) -> Option<&Error>
[src]
fn cause(&self) -> Option<&Error>
The lower-level cause of this error, if any. Read more
impl Display for Error
[src]
impl Display for Error
fn fmt(&self, f: &mut Formatter) -> Result<(), Error>
[src]
fn fmt(&self, f: &mut Formatter) -> Result<(), Error>
Formats the value using the given formatter. Read more
impl Debug for Error
[src]
impl Debug for Error
fn fmt(&self, f: &mut Formatter) -> Result<(), Error>
[src]
fn fmt(&self, f: &mut Formatter) -> Result<(), Error>
Formats the value using the given formatter. Read more
impl From<Error> for Error
[src]
impl From<Error> for Error
impl<T> From<SendError<T>> for Error where
T: 'static + Send,
[src]
impl<T> From<SendError<T>> for Error where
T: 'static + Send,
impl From<Canceled> for Error
[src]
impl From<Canceled> for Error
impl StreamHandler<RespValue, RespError> for RedisActor
[src]
impl StreamHandler<RespValue, RespError> for RedisActor
fn error(&mut self, err: RespError, _: &mut Self::Context) -> Running
[src]
fn error(&mut self, err: RespError, _: &mut Self::Context) -> Running
Method is called when stream emits error. Read more
fn handle(&mut self, msg: RespValue, _: &mut Self::Context)
[src]
fn handle(&mut self, msg: RespValue, _: &mut Self::Context)
Method is called for every message received by this Actor
fn started(&mut self, ctx: &mut Self::Context)
[src]
fn started(&mut self, ctx: &mut Self::Context)
Method is called when stream get polled first time.
fn finished(&mut self, ctx: &mut Self::Context)
[src]
fn finished(&mut self, ctx: &mut Self::Context)
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]
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>,
This method register stream to an actor context and allows to handle Stream
in similar way as normal actor messages. Read more
impl From<Error> for Error
[src]
impl From<Error> for Error