pub trait InHandler: Send {
// Provided methods
fn on_push(
&mut self,
_logic: &mut GraphStageLogic,
_inlet: AnyInlet,
) -> StreamResult<()> { ... }
fn on_upstream_finish(
&mut self,
_logic: &mut GraphStageLogic,
_inlet: AnyInlet,
) -> StreamResult<()> { ... }
fn on_upstream_failure(
&mut self,
logic: &mut GraphStageLogic,
_inlet: AnyInlet,
cause: StreamError,
) -> StreamResult<()> { ... }
}Provided Methods§
fn on_push( &mut self, _logic: &mut GraphStageLogic, _inlet: AnyInlet, ) -> StreamResult<()>
fn on_upstream_finish( &mut self, _logic: &mut GraphStageLogic, _inlet: AnyInlet, ) -> StreamResult<()>
fn on_upstream_failure( &mut self, logic: &mut GraphStageLogic, _inlet: AnyInlet, cause: StreamError, ) -> StreamResult<()>
Dyn Compatibility§
This trait is dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".