Struct FlashblockUpdateSender 

pub struct FlashblockUpdateSender { /* private fields */ }

Cloneable application handle for a subscriber-owned, bounded update queue.

This handle performs no network I/O and implements no retry policy. The application keeps it while the super::AlloySubscriber may be moved into another runtime owner, and sends only updates produced by a compatible adapter. Backpressure, reconnects, and source rotation remain application responsibilities.

Implementations

impl FlashblockUpdateSender

pub const fn provider(&self) -> &ProviderRef

Configured endpoint and initial generation for this queue.

pub async fn send( &self, update: FlashblockUpdate, ) -> Result<(), FlashblockUpdateChannelError>

Await bounded queue capacity, enqueue one standardized update, and wait for the subscriber’s validation verdict.

Errors

Returns FlashblockUpdateChannelError::UnexpectedEndpoint before enqueueing an update from another endpoint, or FlashblockUpdateChannelError::Closed after subscriber shutdown. FlashblockUpdateChannelError::Rejected means the subscriber consumed the update but rejected its integrity or local resource requirements; revoke and replace that source generation before continuing.

pub fn try_send( &self, update: FlashblockUpdate, ) -> Result<FlashblockUpdateAcknowledgement, FlashblockUpdateChannelError>

Enqueue one standardized update without waiting for capacity and return a receipt for the subscriber’s eventual validation verdict.

Errors

In addition to endpoint and closure errors, returns FlashblockUpdateChannelError::Full when the bounded queue has no immediate capacity. A successful return proves only queue admission; await FlashblockUpdateAcknowledgement::wait before treating the update as accepted. The caller decides whether to wait, invalidate its current generation, or reconnect the external source.

Trait Implementations

impl Clone for FlashblockUpdateSender

fn clone(&self) -> FlashblockUpdateSender

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FlashblockUpdateSender

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

Formats the value using the given formatter.