Trait SinkFactory 

pub trait SinkFactory: Send {
    type Sink: ReplicationSink;

    // Required method
    fn connect(&mut self) -> impl Future<Output = Result<Self::Sink>> + Send;
}

Produces sinks; called again after a transient failure.

Required Associated Types

type Sink: ReplicationSink

Required Methods

fn connect(&mut self) -> impl Future<Output = Result<Self::Sink>> + Send

Dyn Compatibility

This trait is not dyn compatible.

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

Implementors