Enum StreamEvent

pub enum StreamEvent {
    InboundSubscriptionRequest(InboundRequest<Subscription>),
    InboundError(ClientError),
    OutboundError(ClientError),
    ConnectionClosed(Option<CloseFrame<'static>>),
}

Possible events produced by the ClientStream.

The events are produced by polling ClientStream in a loop.

Variants

InboundSubscriptionRequest(InboundRequest<Subscription>)

Inbound request for receiving a subscription message.

Currently, Subscription is the only request that the Relay sends to the clients.

InboundError(ClientError)

Error generated when failed to parse an inbound message, invalid request type or message ID.

OutboundError(ClientError)

Error generated when failed to write data to the underlying websocket stream.

ConnectionClosed(Option<CloseFrame<'static>>)

The websocket connection was closed.

This is the last event that can be produced by the stream.

Trait Implementations

impl Debug for StreamEvent

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

Formats the value using the given formatter.