Struct bonsaidb::server::fabruic::Incoming

pub struct Incoming<T>where
    T: DeserializeOwned,{ /* private fields */ }

An intermediate state to define which type to accept in this stream. See accept_stream.

Implementations

impl<T> Incoming<T>where T: DeserializeOwned,

pub async fn type(&mut self) -> impl Future<Output = Result<&T, &Incoming>>

Returns the type information for that stream.

Errors

• error::Incoming::Receiver if receiving the type information to the peer failed, see error::Receiver for more details
• error::Incoming::Closed if the stream was closed

pub async fn accept<S, R>( self ) -> impl Future<Output = Result<(Sender<S>, Receiver<R>), Incoming>>where S: DeserializeOwned + Serialize + Send + 'static, R: DeserializeOwned + Serialize + Send + 'static,

Accept the incoming stream with the given types.

Use S and R to define which type this stream is sending and receiving.

Errors

• error::Incoming::Receiver if receiving the type information to the peer failed, see error::Receiver for more details
• error::Incoming::Closed if the stream was closed

Trait Implementations

impl<T> Debug for Incoming<T>where T: DeserializeOwned,

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

Formats the value using the given formatter.