risingwave_connector::sink::mongodb

Type Alias MongodbSinkDeliveryFuture

source
pub type MongodbSinkDeliveryFuture = impl TryFuture<Ok = (), Error = SinkError> + Unpin + 'static;