Struct secret_handshake::OwningServerHandshakerWithFilter

pub struct OwningServerHandshakerWithFilter<S, FilterFn, AsyncBool> { /* fields omitted */ }

Performs the server side of a handshake. Allows filtering clients based on their longterm public key. This copies the keys so that it isn't constrainted by their lifetime.

Methods

impl<S, FilterFn, AsyncBool> OwningServerHandshakerWithFilter<S, FilterFn, AsyncBool> where
    S: AsyncRead + AsyncWrite,
    FilterFn: FnOnce(&PublicKey) -> AsyncBool,
    AsyncBool: Future<Item = bool>, 

pub fn new(
    stream: S,
    filter_fn: FilterFn,
    network_identifier: [u8; 32],
    server_longterm_pk: PublicKey,
    server_longterm_sk: SecretKey,
    server_ephemeral_pk: PublicKey,
    server_ephemeral_sk: SecretKey
) -> OwningServerHandshakerWithFilter<S, FilterFn, AsyncBool>

Creates a new OwningServerHandshakerWithFilter to accept a connection from a client which knows the server's public key and uses the right app key over the given stream.

Once the client has revealed its longterm public key, filter_fn is invoked. If the returned AsyncBool resolves to Ok(Ready(false)), the handshake is aborted.

Trait Implementations

impl<S, FilterFn, AsyncBool> Future for OwningServerHandshakerWithFilter<S, FilterFn, AsyncBool> where
    S: AsyncRead + AsyncWrite,
    FilterFn: FnOnce(&PublicKey) -> AsyncBool,
    AsyncBool: Future<Item = bool>, 

Future implementation to asynchronously drive a handshake.

type Item = (Outcome, S)

A successful value

type Error = (FilteringHandshakeError<AsyncBool::Error>, S)

An error

fn poll(&mut self, cx: &mut Context) -> Poll<Self::Item, Self::Error>

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.