risingwave_connector::sink::google_pubsub::delivery_future

Function may_delivery_future

source
pub(super) fn may_delivery_future(
    awaiter: Vec<Awaiter>,
) -> impl TryFuture<Ok = (), Error = SinkError> + Unpin + 'static