Module worker 

For single-thread flow worker

Structs

ActiveDataflowState 🔒

ActiveDataflowState is a wrapper around Dfir 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