Struct InputPipelineAssembly 

pub struct InputPipelineAssembly { /* private fields */ }

An input pipeline assembly.

Represents a partial stage of the input pipeline which accepts inputs through an asynchronous sender channel, and emits outputs through an asynchronous receiver channel. Use [new] to create a new assembly. Use [add_handler], or [add_all_handlers] to add the input pipeline handlers to use. When done, InputPipeline::new can be used to make a new input pipeline.

Implementation notes

Internally, when a new InputPipelineAssembly is created with multiple [InputHandler]s, the handlers are connected together using async queues. This allows fully streamed processing of input events, and also allows some pipeline stages to generate events spontaneously, i.e. without an external stimulus.

Implementations

impl InputPipelineAssembly

pub fn new(metrics_logger: MetricsLogger) -> Self

Create a new but empty InputPipelineAssembly. Use [add_handler] or similar to add new handlers to it.

pub fn add_handler(self, handler: Rc<dyn BatchInputHandler>) -> Self

Adds another input_handler::BatchInputHandler into the InputPipelineAssembly. The handlers are invoked in the order they are added. Returns Self for chaining.

pub fn add_all_handlers(self, handlers: Vec<Rc<dyn BatchInputHandler>>) -> Self

Adds all handlers into the assembly in the order they appear in handlers.

pub fn add_display_ownership( self, display_ownership_event: Event, input_handlers_node: &Node, ) -> InputPipelineAssembly

pub fn add_focus_listener( self, focus_chain_publisher: FocusChainProviderPublisher, ) -> Self