Structs

An iterator that will yield all the remaining messages from the workers, and join them once they have all dropped their receiver.

An iterator that will yield received messages until the message queue has been caught up to when the iterator was created.

A message sent from a worker to the manager; contains the timestamp of its creation to allow RecvBurstIterator to stop early

The main struct, represents a pool of worker. The owner of this struct is the “Manager”, while the threads handled by this struct are the “Workers”.

A wrapper around Sender<UpMsg>. This type implements !Send, as RecvAllIterator depends on this type being dropped whenever the thread holding it stops

Enums

A message sent from the manager to the workers

Type Definitions