risingwave_connector::sink::pulsar

Type Alias PulsarDeliveryFuture

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