Enum actix_redis::RespValue
[−]
[src]
pub enum RespValue { Nil, Array(Vec<RespValue>), BulkString(Vec<u8>), Error(String), Integer(i64), SimpleString(String), }
A single RESP value, this owns the data that is read/to-be written to Redis.
It is cloneable to allow multiple copies to be delivered in certain circumstances, e.g. multiple subscribers to the same topic.
Variants
Nil
Array(Vec<RespValue>)
Zero, one or more other RespValue
s.
BulkString(Vec<u8>)
A bulk string. In Redis terminology a string is a byte-array, so this is stored as a
vector of u8
s to allow clients to interpret the bytes as appropriate.
Error(String)
An error from the Redis server
Integer(i64)
Redis documentation defines an integer as being a signed 64-bit integer: https://redis.io/topics/protocol#resp-integers
SimpleString(String)
Trait Implementations
impl FromResp for RespValue
[src]
fn from_resp_int(resp: RespValue) -> Result<RespValue, Error>
[src]
fn from_resp(resp: RespValue) -> Result<Self, Error>
[src]
Return a Result
containing either Self
or Error
. Errors can occur due to either: a) the particular RespValue
being incompatible with the required type, or b) a remote Redis error occuring. Read more
impl Eq for RespValue
[src]
impl PartialEq<RespValue> for RespValue
[src]
fn eq(&self, __arg_0: &RespValue) -> bool
[src]
This method tests for self
and other
values to be equal, and is used by ==
. Read more
fn ne(&self, __arg_0: &RespValue) -> bool
[src]
This method tests for !=
.
impl<'a> From<&'a String> for RespValue
[src]
impl<'a> From<&'a str> for RespValue
[src]
impl<'a> From<usize> for RespValue
[src]
impl<'a> From<Vec<u8>> for RespValue
[src]
impl<'a> From<&'a [u8]> for RespValue
[src]
impl<'a> From<String> for RespValue
[src]
impl Clone for RespValue
[src]
fn clone(&self) -> RespValue
[src]
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)
1.0.0[src]
Performs copy-assignment from source
. Read more
impl Debug for RespValue
[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