Struct Session 

pub struct Session { /* private fields */ }

Represents an open subscribe session.

This is a stream-like struct for serving messages to an application.

Example

let mut session = client
    .streaming_pull("projects/my-project/subscriptions/my-subscription")
    .start();
while let Some((m, h)) = session.next().await.transpose()? {
    println!("Received message m={m:?}");
    h.ack();
}

Implementations

impl Session

pub async fn next(&mut self) -> Option<Result<(PubsubMessage, Handler)>>

Returns the next message received on this subscription.

The message data is returned along with a Handler for acknowledging (ack) or rejecting (nack) the message.

If the underlying stream encounters a permanent error, an Error is returned instead.

None represents the end of a stream, but in practice, the stream stays open until it is cancelled or encounters a permanent error.

Example

while let Some((m, h)) = session.next().await.transpose()? {
    println!("Received message m={m:?}");
    h.ack();
}

Trait Implementations

impl Debug for Session

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.