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) -> 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) -> 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.