Trait StreamProcessorProxyInterface 

pub trait StreamProcessorProxyInterface: Send + Sync {
    type SyncResponseFut: Future<Output = Result<(), Error>> + Send;
    type RemoveBufferResponseFut: 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>;
    fn participate_in_buffer_allocation(
        &self,
        payload: StreamProcessorParticipateInBufferAllocationRequest,
    ) -> Result<(), Error>;
    fn add_buffer(
        &self,
        payload: StreamProcessorAddBufferRequest,
    ) -> Result<(), Error>;
    fn remove_buffer(
        &self,
        payload: StreamProcessorRemoveBufferRequest,
    ) -> Self::RemoveBufferResponseFut;
    fn enable_old_output_buffers(&self) -> Result<(), Error>;
    fn enable_same_output_buffer_concurrently_in_flight(
        &self,
    ) -> Result<(), Error>;
    fn enable_force_output_buffers_fixed_image_size(&self) -> Result<(), Error>;
}

Required Associated Types

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

type RemoveBufferResponseFut: 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>

fn participate_in_buffer_allocation( &self, payload: StreamProcessorParticipateInBufferAllocationRequest, ) -> Result<(), Error>

fn add_buffer( &self, payload: StreamProcessorAddBufferRequest, ) -> Result<(), Error>

fn remove_buffer( &self, payload: StreamProcessorRemoveBufferRequest, ) -> Self::RemoveBufferResponseFut

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

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

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

Implementors

impl StreamProcessorProxyInterface for StreamProcessorProxy

type SyncResponseFut = QueryResponseFut<()>

type RemoveBufferResponseFut = QueryResponseFut<()>