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>;
}