Expand description
Types to build async operators with general shapes.
Structs§
- Async
Input Handle - Async handle to an operator’s input stream
- Async
Output Handle - Button
- Button
Handle - A button that can be used to coordinate an action after all workers have pressed it.
- Connected
ToMany - A marker type representing an input connected to many outputs.
- Connected
ToOne - A marker type representing an input connected to exactly one output.
- Disconnected
- A marker type representing a disconnected input.
- Input
Handle 🔒Queue - Operator
Builder - Builds async operators with generic shape.
- Press
OnDrop Button - Timely
Waker 🔒 - An async Waker that activates a specific operator when woken and marks the task as ready
Enums§
- Event
- An event of an input stream
Traits§
- Input
Connection - A trait describing the connection behavior between an input of an operator and zero or more of its outputs.
- Input
Queue 🔒 - A helper trait abstracting over an input handle. It facilitates keeping around type erased handles for each of the operator inputs.
- Output
Index - A helper trait abstracting over an output handle. It facilitates passing type erased output handles during operator construction. It is not meant to be implemented by users.
Functions§
- button
- Creates a new coordinated button the worker configuration described by
scope.