pub trait StreamSinkProxyInterface: Send + Sync {
// Required methods
fn put_packet(
&self,
payload: StreamSinkPutPacketRequest
) -> Result<(), Error>;
fn start_segment(
&self,
payload: &StreamSinkStartSegmentRequest
) -> Result<(), Error>;
fn end(&self) -> Result<(), Error>;
fn will_close(
&self,
payload: &StreamSinkWillCloseRequest
) -> Result<(), Error>;
}