Enum ProviderProto 

pub enum ProviderProto {
    ClientConnected(ClientConnected),
    ClientConnectedNotify(Notify<ClientConnected>),
    ConnectionClosed(ConnectionClosed),
    GetRequestReceived(RequestReceived<GetRequest>),
    GetRequestReceivedNotify(Notify<RequestReceived<GetRequest>>),
    GetManyRequestReceived(RequestReceived<GetManyRequest>),
    GetManyRequestReceivedNotify(Notify<RequestReceived<GetManyRequest>>),
    PushRequestReceived(RequestReceived<PushRequest>),
    PushRequestReceivedNotify(Notify<RequestReceived<PushRequest>>),
    ObserveRequestReceived(RequestReceived<ObserveRequest>),
    ObserveRequestReceivedNotify(Notify<RequestReceived<ObserveRequest>>),
    Throttle(Throttle),
}

Variants

ClientConnected(ClientConnected)

A new client connected to the provider.

ClientConnectedNotify(Notify<ClientConnected>)

A new client connected to the provider. Notify variant.

ConnectionClosed(ConnectionClosed)

A client disconnected from the provider.

GetRequestReceived(RequestReceived<GetRequest>)

A new get request was received from the provider.

GetRequestReceivedNotify(Notify<RequestReceived<GetRequest>>)

A new get request was received from the provider (notify variant).

GetManyRequestReceived(RequestReceived<GetManyRequest>)

A new get many request was received from the provider.

GetManyRequestReceivedNotify(Notify<RequestReceived<GetManyRequest>>)

A new get many request was received from the provider (notify variant).

PushRequestReceived(RequestReceived<PushRequest>)

A new push request was received from the provider.

PushRequestReceivedNotify(Notify<RequestReceived<PushRequest>>)

A new push request was received from the provider (notify variant).

ObserveRequestReceived(RequestReceived<ObserveRequest>)

A new observe request was received from the provider.

ObserveRequestReceivedNotify(Notify<RequestReceived<ObserveRequest>>)

A new observe request was received from the provider (notify variant).

Throttle(Throttle)

Request to throttle sending for a specific data request.

Trait Implementations

impl Channels<ProviderProto> for ClientConnected

type Tx = Sender<Result<(), AbortReason>>

The sender type, can be either mpsc, oneshot or none

type Rx = NoReceiver

The receiver type, can be either mpsc, oneshot or none

impl Channels<ProviderProto> for ConnectionClosed

type Tx = NoSender

The sender type, can be either mpsc, oneshot or none

type Rx = NoReceiver

The receiver type, can be either mpsc, oneshot or none

impl Channels<ProviderProto> for Notify<ClientConnected>

type Tx = NoSender

The sender type, can be either mpsc, oneshot or none

type Rx = NoReceiver

The receiver type, can be either mpsc, oneshot or none

impl Channels<ProviderProto> for Notify<RequestReceived<GetManyRequest>>

type Tx = NoSender

The sender type, can be either mpsc, oneshot or none

type Rx = Receiver<RequestUpdate>

The receiver type, can be either mpsc, oneshot or none

impl Channels<ProviderProto> for Notify<RequestReceived<GetRequest>>

type Tx = NoSender

The sender type, can be either mpsc, oneshot or none

type Rx = Receiver<RequestUpdate>

The receiver type, can be either mpsc, oneshot or none

impl Channels<ProviderProto> for Notify<RequestReceived<ObserveRequest>>

type Tx = NoSender

The sender type, can be either mpsc, oneshot or none

type Rx = Receiver<RequestUpdate>

The receiver type, can be either mpsc, oneshot or none

impl Channels<ProviderProto> for Notify<RequestReceived<PushRequest>>

type Tx = NoSender

The sender type, can be either mpsc, oneshot or none

type Rx = Receiver<RequestUpdate>

The receiver type, can be either mpsc, oneshot or none

impl Channels<ProviderProto> for RequestReceived<GetManyRequest>

type Tx = Sender<Result<(), AbortReason>>

The sender type, can be either mpsc, oneshot or none

type Rx = Receiver<RequestUpdate>

The receiver type, can be either mpsc, oneshot or none

impl Channels<ProviderProto> for RequestReceived<GetRequest>

type Tx = Sender<Result<(), AbortReason>>

The sender type, can be either mpsc, oneshot or none

type Rx = Receiver<RequestUpdate>

The receiver type, can be either mpsc, oneshot or none

impl Channels<ProviderProto> for RequestReceived<ObserveRequest>

type Tx = Sender<Result<(), AbortReason>>

The sender type, can be either mpsc, oneshot or none

type Rx = Receiver<RequestUpdate>

The receiver type, can be either mpsc, oneshot or none

impl Channels<ProviderProto> for RequestReceived<PushRequest>

type Tx = Sender<Result<(), AbortReason>>

The sender type, can be either mpsc, oneshot or none

type Rx = Receiver<RequestUpdate>

The receiver type, can be either mpsc, oneshot or none

impl Channels<ProviderProto> for Throttle

type Tx = Sender<Result<(), AbortReason>>

The sender type, can be either mpsc, oneshot or none

type Rx = NoReceiver

The receiver type, can be either mpsc, oneshot or none

impl Debug for ProviderProto

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ProviderProto

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<ClientConnected> for ProviderProto

fn from(value: ClientConnected) -> Self

Converts to this type from the input type.

impl From<ConnectionClosed> for ProviderProto

fn from(value: ConnectionClosed) -> Self

Converts to this type from the input type.

impl From<Notify<ClientConnected>> for ProviderProto

fn from(value: Notify<ClientConnected>) -> Self

Converts to this type from the input type.

impl From<Notify<RequestReceived<GetManyRequest>>> for ProviderProto

fn from(value: Notify<RequestReceived<GetManyRequest>>) -> Self

Converts to this type from the input type.

impl From<Notify<RequestReceived<GetRequest>>> for ProviderProto

fn from(value: Notify<RequestReceived<GetRequest>>) -> Self

Converts to this type from the input type.

impl From<Notify<RequestReceived<ObserveRequest>>> for ProviderProto

fn from(value: Notify<RequestReceived<ObserveRequest>>) -> Self

Converts to this type from the input type.

impl From<Notify<RequestReceived<PushRequest>>> for ProviderProto

fn from(value: Notify<RequestReceived<PushRequest>>) -> Self

Converts to this type from the input type.

impl From<RequestReceived<GetManyRequest>> for ProviderProto

fn from(value: RequestReceived<GetManyRequest>) -> Self

Converts to this type from the input type.

impl From<RequestReceived<GetRequest>> for ProviderProto

fn from(value: RequestReceived<GetRequest>) -> Self

Converts to this type from the input type.

impl From<RequestReceived<ObserveRequest>> for ProviderProto

fn from(value: RequestReceived<ObserveRequest>) -> Self

Converts to this type from the input type.

impl From<RequestReceived<PushRequest>> for ProviderProto

fn from(value: RequestReceived<PushRequest>) -> Self

Converts to this type from the input type.

impl From<Throttle> for ProviderProto

fn from(value: Throttle) -> Self

Converts to this type from the input type.

impl RemoteService for ProviderProto

fn with_remote_channels(self, rx: RecvStream, tx: SendStream) -> Self::Message

Returns the message enum for this request by combining self (the protocol enum) with a pair of QUIC streams for tx and rx channels.

fn remote_handler( local_sender: LocalSender<Self>, ) -> Arc<dyn Fn(Self, RecvStream, SendStream) -> Pin<Box<dyn Future<Output = Result<(), SendError>> + Send>> + Send + Sync>

Creates a [Handler] that forwards all messages to a [LocalSender].

impl Serialize for ProviderProto

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Service for ProviderProto

type Message = ProviderMessage

Message enum for this protocol.