Module worker

For single-thread flow worker

Structs

• ActiveDataflowState 🔒
  ActiveDataflowState is a wrapper around Hydroflow and DataflowState
• InterThreadCallClient 🔒
• InterThreadCallServer 🔒
• Worker
  The actual worker that does the work and contain active state
• WorkerHandle

Enums

• Request
• Response 🔒

Functions

• create_inter_thread_call 🔒
• create_worker
  Create both worker(!Send) and worker handle(Send + Sync)
• from_send_error 🔒

Type Aliases

• ReqId 🔒
• SharedBuf