Struct AsyncSubscriber 

pub struct AsyncSubscriber { /* private fields */ }

Subscribed async TCP-RESP connection. Mirrors [kevy_client::Subscriber] for TCP backends.

Implementations

impl AsyncSubscriber

pub async fn connect(url: &str) -> Result<Self>

Open a fresh connection without subscribing yet. Call Self::subscribe / Self::psubscribe next.

pub async fn open(url: &str, channels: &[&[u8]]) -> Result<Self>

Open and subscribe to one or more channels in one step.

pub async fn subscribe(&mut self, channels: &[&[u8]]) -> Result<()>

SUBSCRIBE channel [channel ...]. Per-channel Subscribe acks arrive via Self::recv.

pub async fn psubscribe(&mut self, patterns: &[&[u8]]) -> Result<()>

PSUBSCRIBE pattern [pattern ...].

pub async fn unsubscribe(&mut self, channels: &[&[u8]]) -> Result<()>

UNSUBSCRIBE [channel ...]. Empty list = unsubscribe all.

pub async fn punsubscribe(&mut self, patterns: &[&[u8]]) -> Result<()>

PUNSUBSCRIBE [pattern ...]. Empty list = unsubscribe all.

pub async fn recv(&mut self) -> Result<PubsubEvent>

Await the next pubsub frame. Connection close = UnexpectedEof.

pub async fn recv_message(&mut self) -> Result<(Vec<u8>, Vec<u8>)>

Skip subscription-ack frames and return the next published Message / Pmessage. Returns (channel, payload); for pattern matches channel is the concrete publish channel (the matched pattern is discarded — use Self::recv if you need it).

pub async fn hello3(&mut self) -> Result<PubsubEvent>

Negotiate RESP3 on this connection (HELLO 3). Must run BEFORE any subscribe — Redis spec requires HELLO be the first command. Returns a synthetic PubsubEvent::Subscribe marker (matching the blocking client) so callers can pattern-match a uniform type.