Trait StreamProcessorProxyInterface 

pub trait StreamProcessorProxyInterface: Send + Sync {
    type SyncResponseFut: Future<Output = Result<(), Error>> + Send;

    // Required methods
    fn enable_on_stream_failed(&self) -> Result<(), Error>;
    fn set_input_buffer_partial_settings(
        &self,
        input_settings: StreamBufferPartialSettings,
    ) -> Result<(), Error>;
    fn set_output_buffer_partial_settings(
        &self,
        output_settings: StreamBufferPartialSettings,
    ) -> Result<(), Error>;
    fn complete_output_buffer_partial_settings(
        &self,
        buffer_lifetime_ordinal: u64,
    ) -> Result<(), Error>;
    fn flush_end_of_stream_and_close_stream(
        &self,
        stream_lifetime_ordinal: u64,
    ) -> Result<(), Error>;
    fn close_current_stream(
        &self,
        stream_lifetime_ordinal: u64,
        release_input_buffers: bool,
        release_output_buffers: bool,
    ) -> Result<(), Error>;
    fn sync(&self) -> Self::SyncResponseFut;
    fn recycle_output_packet(
        &self,
        available_output_packet: &PacketHeader,
    ) -> Result<(), Error>;
    fn queue_input_format_details(
        &self,
        stream_lifetime_ordinal: u64,
        format_details: &FormatDetails,
    ) -> Result<(), Error>;
    fn queue_input_packet(&self, packet: &Packet) -> Result<(), Error>;
    fn queue_input_end_of_stream(
        &self,
        stream_lifetime_ordinal: u64,
    ) -> Result<(), Error>;
}

Required Associated Types

type SyncResponseFut: Future<Output = Result<(), Error>> + Send

Required Methods

fn enable_on_stream_failed(&self) -> Result<(), Error>

fn set_input_buffer_partial_settings( &self, input_settings: StreamBufferPartialSettings, ) -> Result<(), Error>

fn set_output_buffer_partial_settings( &self, output_settings: StreamBufferPartialSettings, ) -> Result<(), Error>

fn complete_output_buffer_partial_settings( &self, buffer_lifetime_ordinal: u64, ) -> Result<(), Error>

fn flush_end_of_stream_and_close_stream( &self, stream_lifetime_ordinal: u64, ) -> Result<(), Error>

fn close_current_stream( &self, stream_lifetime_ordinal: u64, release_input_buffers: bool, release_output_buffers: bool, ) -> Result<(), Error>

fn sync(&self) -> Self::SyncResponseFut

fn recycle_output_packet( &self, available_output_packet: &PacketHeader, ) -> Result<(), Error>

fn queue_input_format_details( &self, stream_lifetime_ordinal: u64, format_details: &FormatDetails, ) -> Result<(), Error>

fn queue_input_packet(&self, packet: &Packet) -> Result<(), Error>

fn queue_input_end_of_stream( &self, stream_lifetime_ordinal: u64, ) -> Result<(), Error>

Implementors

impl StreamProcessorProxyInterface for StreamProcessorProxy

type SyncResponseFut = QueryResponseFut<()>