risingwave_connector::sink::nats

Type Alias NatsSinkDeliveryFuture

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