Module mz_timely_util::builder_async

Types to build async operators with general shapes.

Structs

• AsyncInputHandle
  Async handle to an operator’s input stream
• AsyncOutputHandle
• Button
• ButtonHandle
  A button that can be used to coordinate an action after all workers have pressed it.
• ConnectedToMany
  A marker type representing an input connected to many outputs.
• ConnectedToOne
  A marker type representing an input connected to exactly one output.
• Disconnected
  A marker type representing a disconnected input.
• InputHandleQueue 🔒
• OperatorBuilder
  Builds async operators with generic shape.
• PressOnDropButton
• TimelyWaker 🔒
  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

• InputConnection
  A trait describing the connection behavior between an input of an operator and zero or more of its outputs.
• InputQueue 🔒
  A helper trait abstracting over an input handle. It facilitates keeping around type erased handles for each of the operator inputs.
• OutputIndex
  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.