Trait Sink 

pub trait Sink<I>: Provider
where
    I: Send + 'static,
{
    // Required method
    fn send(
        &self,
        input: I,
    ) -> impl Future<Output = Result<(), AppError>> + Send;
}

Write-only (Kafka publish, webhook, S3 put, log sink).

Implementations must apply downstream backpressure or return a typed error instead of buffering without a bound.

Required Methods

fn send(&self, input: I) -> impl Future<Output = Result<(), AppError>> + Send

Send a single item downstream.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors