Trait ConnectableAsync 

pub trait ConnectableAsync<Ctx> {
    type Output;

    // Required method
    fn connect(self, ctx: Ctx) -> impl Future<Output = Self::Output>;
}

Available on crate feature build only.

Required Associated Types

type Output

Required Methods

fn connect(self, ctx: Ctx) -> impl Future<Output = Self::Output>

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<'a, D: Deploy<'a>, M> ConnectableAsync<&DeployResult<'a, D>> for ExternalBytesPort<M>

type Output = (Pin<Box<dyn Stream<Item = Result<BytesMut, Error>>>>, Pin<Box<dyn Sink<Bytes, Error = Error>>>)

impl<'a, D: Deploy<'a>, T: DeserializeOwned + 'static, O: Ordering, R: Retries> ConnectableAsync<&DeployResult<'a, D>> for ExternalBincodeStream<T, O, R>

type Output = Pin<Box<dyn Stream<Item = T>>>

impl<'a, D: Deploy<'a>, T: Serialize + 'static, Many> ConnectableAsync<&DeployResult<'a, D>> for ExternalBincodeSink<T, Many>

type Output = Pin<Box<dyn Sink<T, Error = Error>>>