Struct ChannelListener 

pub struct ChannelListener { /* private fields */ }

A live subscription to one Channel, returned by crate::Client::listen.

Holds a dedicated (non-pooled) connection for as long as it’s alive — LISTEN is per-session, so sharing a pooled connection would leak the subscription onto whatever unrelated query later borrows that same connection back out of the pool. Dropping this closes the connection and ends the server-side subscription with it.

Implementations

impl ChannelListener

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

Waits for the next decoded payload. Returns None once the dedicated connection closes, or once a payload has failed to decode.

A malformed payload yields Err(Error::MalformedPayload(_)) and ends the subscription — every later call returns None. A channel is a database-wide name, so anything can publish to it; failing hard keeps foreign data on a typed channel visible instead of silently dropped, and not resuming keeps that failure from being papered over by the next good message.

A consumer that needs to stay subscribed past a bad message re-subscribes itself:

loop {
    let mut sub = client.listen("UserUpdates").await?;
    while let Some(payload) = sub.recv().await {
        match payload {
            Ok(v) => handle(v),
            Err(e) => { log(e); break; }  // re-listen on the next pass
        }
    }
}

This matches Client.listen() on the Python side, where the same failure raises out of the async for and ends the generator.