pub trait AsyncTruncateSinkWriter: Send + 'static {
type DeliveryFuture: TryFuture<Ok = (), Error = SinkError> + Unpin + Send + 'static = Ready<Result<(), SinkError>>;
// Required method
fn write_chunk<'a>(
&'a mut self,
chunk: StreamChunk,
add_future: DeliveryFutureManagerAddFuture<'a, Self::DeliveryFuture>,
) -> impl Future<Output = Result<()>> + Send + 'a;
// Provided method
fn barrier(
&mut self,
_is_checkpoint: bool,
) -> impl Future<Output = Result<()>> + Send + '_ { ... }
}Provided Associated Types§
type DeliveryFuture: TryFuture<Ok = (), Error = SinkError> + Unpin + Send + 'static = Ready<Result<(), SinkError>>
Required Methods§
fn write_chunk<'a>( &'a mut self, chunk: StreamChunk, add_future: DeliveryFutureManagerAddFuture<'a, Self::DeliveryFuture>, ) -> impl Future<Output = Result<()>> + Send + 'a
Provided Methods§
fn barrier( &mut self, _is_checkpoint: bool, ) -> impl Future<Output = Result<()>> + Send + '_
Object Safety§
This trait is not object safe.