[][src]Module tari_service_framework::reply_channel

Structs

Receiver

Receiver side of the reply channel. This is functionally equivalent to rx.map(|(req, reply_tx)| RequestContext::new(req, reply_tx)) but is ergonomically better to use with the futures::select macro (implements FusedStream) and has a short type signature.

RequestContext

This is the object received on the Receiver-side of this channel. It's a simple wrapper with some convenience functions used to reply to the request.

SenderService

Requester is sends requests on a given Tx sender and returns a AwaitResponseFuture which will resolve to the generic TRes.

TransportResponseFuture

Response future for Results received over a given oneshot channel Receiver.

Enums

TransportChannelError

Functions

unbounded

Create a new Requester/Responder pair which wraps and calls the given service

Type Definitions

TryReceiver
TrySenderService