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