Enum AppendRecord 

pub enum AppendRecord {
    Bytes(Bytes),
    Stream(Pin<Box<dyn AsyncRead + Send>>),
}

Available on crate feature inspect only.

Append an owned stream. Success publishes the record; cancellation aborts it.

Variants

Bytes(Bytes)

An already owned record; memory storage retains these bytes without copying.

Stream(Pin<Box<dyn AsyncRead + Send>>)

A streaming source, read with backpressure and bounded scratch space.

Implementations

impl AppendRecord

pub fn new(source: impl AsyncRead + Send + 'static) -> AppendRecord

pub fn bytes(bytes: Bytes) -> AppendRecord

pub fn into_reader(self) -> Pin<Box<dyn AsyncRead + Send>>

Trait Implementations

impl Debug for AppendRecord

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Service<AppendRecord> for Collection

type Output = RecordId

The type of the output returned by the service.

type Error = Box<dyn Error + Send + Sync>

The type of error returned by the service.

async fn serve( &self, input: AppendRecord, ) -> Result<<Collection as Service<AppendRecord>>::Output, <Collection as Service<AppendRecord>>::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.

impl Service<AppendRecord> for CollectionWriter

type Output = RecordId

The type of the output returned by the service.

type Error = Box<dyn Error + Send + Sync>

The type of error returned by the service.

async fn serve( &self, input: AppendRecord, ) -> Result<<CollectionWriter as Service<AppendRecord>>::Output, <CollectionWriter as Service<AppendRecord>>::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.