Struct ServiceInputSender 

pub struct ServiceInputSender { /* private fields */ }

Cloneable, non-blocking send capability for one exact process generation.

Serialization happens on the caller and the bounded queue is entered only with try_send; this API never awaits service I/O or queue capacity. A successful send means queue admission, not durable delivery: stopping or restarting the generation may discard records that the writer has not yet completed. written_lines advances only after a full write and flush.

Implementations

impl ServiceInputSender

pub fn generation(&self) -> u64

pub fn try_send<T>(&self, value: &T) -> Result<(), ServiceInputSendError>

where T: Serialize + ?Sized,

Serialize one value and enqueue exactly one newline-terminated JSON record. Newlines inside strings remain JSON escapes, so one accepted call always corresponds to one physical NDJSON line.

Trait Implementations

impl Clone for ServiceInputSender

fn clone(&self) -> ServiceInputSender

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.