Struct openraft::impls::OneshotResponder

pub struct OneshotResponder<C>
where
    C: RaftTypeConfig,
{ /* private fields */ }

A Responder implementation that sends the response via a oneshot channel.

This could be used when the Raft::client_write caller want to wait for the response.

Implementations

impl<C> OneshotResponder<C>

where C: RaftTypeConfig,

pub fn new( tx: <<C as RaftTypeConfig>::AsyncRuntime as AsyncRuntime>::OneshotSender<ClientWriteResult<C>> ) -> Self

Create a new instance from a AsyncRuntime::OneshotSender.

Trait Implementations

impl<C> Responder<C> for OneshotResponder<C>

where C: RaftTypeConfig,

type Receiver = <<C as RaftTypeConfig>::AsyncRuntime as AsyncRuntime>::OneshotReceiver<Result<ClientWriteResponse<C>, ClientWriteError<<C as RaftTypeConfig>::NodeId, <C as RaftTypeConfig>::Node>>>

An optional receiver to receive the result sent by RaftCore.

fn from_app_data(app_data: C::D) -> (C::D, Self, Self::Receiver)

where Self: Sized,

Build a new instance from the application request.

fn send(self, res: ClientWriteResult<C>)

Send result when the request has been completed.