Struct kernel::registry::listener::Accept

pub struct Accept<D: RegisteredDriver> {
    pub(super) reply: Sender<Result<KProducer<Message<D>>, D::ConnectError>>,
}

Accepts or rejects an incoming connection Handshake.

Fields

reply: Sender<Result<KProducer<Message<D>>, D::ConnectError>>

Implementations

impl<D: RegisteredDriver> Accept<D>

pub fn accept(self, channel: KProducer<Message<D>>) -> Result<(), AcceptError>

Accept the connection, returning the provided channel to the client.

Any requests sent by the client once the connection has been accepted will now be received by the KConsumer corresponding to the provided KProducer.

Returns

• Ok([()]) if the connection was successfully accepted.
• Err(AcceptError) if the connection was canceled by the client. In this case, the client is no longer interested in the connection (and may or may not still exist), and the service may ignore this connection request.

pub fn reject(self, error: D::ConnectError) -> Result<(), AcceptError>

Reject the connection, returning the provided error to the client.

Returns

• Ok([()]) if the connection was successfully rejected and the error was received by the client.
• Err(AcceptError) if the connection was canceled by the client.