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", so this trait is not object safe.

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

impl<'a, T: DeserializeOwned + 'static, O: Ordering, R: Retries> ConnectableAsync<&mut CompiledSimInstance<'a>> for &ExternalBincodeStream<T, O, R>

Available on crate feature sim only.

type Output = SimReceiver<'a, T, O, R>

impl<'a, T: Serialize + 'static, M, O: Ordering, R: Retries> ConnectableAsync<&mut CompiledSimInstance<'a>> for &ExternalBincodeSink<T, M, O, R>

Available on crate feature sim only.

type Output = SimSender<T, O, R>