Struct RedisPubSubMsgDataSrcAsync 

pub struct RedisPubSubMsgDataSrcAsync { /* private fields */ }

Available on crate features standalone-async or sentinel-async or cluster-async only.

A struct that holds a Redis Pub/Sub message as an asynchronous data source.

Implementations

impl RedisPubSubMsgDataSrcAsync

pub fn new(msg: Msg) -> Self

Creates a new RedisPubSubMsgDataSrcAsync with a Redis Pub/Sub message.

Arguments

• msg - A redis::Msg received from an asynchronous Pub/Sub subscriber.

Returns

A new instance of RedisPubSubMsgDataSrcAsync.

Trait Implementations

impl DataSrc<RedisPubSubMsgDataConnAsync> for RedisPubSubMsgDataSrcAsync

async fn setup_async(&mut self, _ag: &mut AsyncGroup) -> Result<()>

Performs asynchronous setup operations for the data source.

fn close(&mut self)

Closes the data source, releasing any associated resources.

async fn create_data_conn_async( &mut self, ) -> Result<Box<RedisPubSubMsgDataConnAsync>>

Asynchronously creates a new data connection from this data source.