risingwave_connector::sink::kinesis

Type Alias KinesisSinkPayloadWriterDeliveryFuture

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