Struct StreamProcessorControlHandle

pub struct StreamProcessorControlHandle { /* private fields */ }

Implementations

impl StreamProcessorControlHandle

pub fn send_on_stream_failed( &self, stream_lifetime_ordinal: u64, error: StreamError, ) -> Result<(), Error>

pub fn send_on_input_constraints( &self, input_constraints: &StreamBufferConstraints, ) -> Result<(), Error>

pub fn send_on_output_constraints( &self, output_config: &StreamOutputConstraints, ) -> Result<(), Error>

pub fn send_on_output_format( &self, output_format: &StreamOutputFormat, ) -> Result<(), Error>

pub fn send_on_output_packet( &self, output_packet: &Packet, error_detected_before: bool, error_detected_during: bool, ) -> Result<(), Error>

pub fn send_on_output_end_of_stream( &self, stream_lifetime_ordinal: u64, error_detected_before: bool, ) -> Result<(), Error>

pub fn send_on_free_input_packet( &self, free_input_packet: &PacketHeader, ) -> Result<(), Error>

Trait Implementations

impl Clone for StreamProcessorControlHandle

fn clone(&self) -> StreamProcessorControlHandle

Returns a copy of the value.

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

Performs copy-assignment from source.

impl ControlHandle for StreamProcessorControlHandle

fn shutdown(&self)

Set the server to shutdown. The underlying channel is only closed the next time the stream is polled.

fn shutdown_with_epitaph(&self, status: Status)

Sets the server to shutdown with an epitaph. The underlying channel is only closed the next time the stream is polled.

fn is_closed(&self) -> bool

Returns true if the server has received the PEER_CLOSED signal.

fn on_closed(&self) -> OnSignalsRef<'_>

Returns a future that completes when the server receives the PEER_CLOSED signal.

fn signal_peer( &self, clear_mask: Signals, set_mask: Signals, ) -> Result<(), Status>

Sets and clears the signals provided on peer handle.

impl Debug for StreamProcessorControlHandle

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

Formats the value using the given formatter.