Enum Subscription 

pub enum Subscription {
    Tcp(SubscriptionStream),
    Ws(WebSocketSubscriptionStream),
}

One channel subscription on the seat’s transport.

Variants

Tcp(SubscriptionStream)

The raw wire.

Ws(WebSocketSubscriptionStream)

The WebSocket door.

Implementations

impl Subscription

pub fn open( address: &str, channel: &str, credential: &[u8], ) -> Result<Self, SdkError>

Subscribes to channel at address carrying credential.

Errors

The SDK’s refusal of the dial, the pass or the subscribe.

pub fn recv(&self) -> Result<DeliveredMessage, SdkError>

Blocks on a delivery or the subscription’s end, without a timer.

Errors

The server’s terminal, a reader failure or a local close.

pub fn recv_timeout( &self, timeout: Duration, ) -> Result<DeliveredMessage, SdkError>

Blocks up to timeout for the next delivery.

Errors

No delivery within timeout, or the subscription’s end.

pub fn close_handle(&self) -> Result<Close, SdkError>

A close signal held apart from the subscription.

Errors

The socket-clone failure.

Trait Implementations

impl Debug for Subscription

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

Formats the value using the given formatter.