Struct wrpc_transport::IncomingInvocation

pub struct IncomingInvocation<Ctx, Sub: Subscriber, Acc: Acceptor> {
    pub context: Ctx,
    pub payload: Bytes,
    pub param_subject: Acc::Subject,
    pub error_subject: Acc::Subject,
    pub handshake_subject: Sub::Subject,
    pub subscriber: Sub,
    pub acceptor: Acc,
}

Invocation received from a peer

Fields

context: Ctx

payload: Bytes

param_subject: Acc::Subject

error_subject: Acc::Subject

handshake_subject: Sub::Subject

subscriber: Sub

acceptor: Acc

Implementations

impl<Ctx, Sub, Acc> IncomingInvocation<Ctx, Sub, Acc>

where Acc: Acceptor, Acc::Subject: Clone, Sub: Subscriber<Subject = Acc::Subject, SubscribeError = Error, StreamError = Error> + Send, Sub::Stream: 'static,

pub async fn accept_static<'a, T: Receive<'a> + Subscribe + 'static>( self ) -> Result<AcceptedInvocation<Ctx, T, <Acc as Acceptor>::Transmitter>>

Accept with statically-typed parameter type T

pub async fn accept_dynamic( self, params: Arc<[Type]> ) -> Result<AcceptedInvocation<Ctx, Vec<Value>, <Acc as Acceptor>::Transmitter>>

Accept with dynamically-typed parameter type params