THub

Publishes a message to the hub, returning whether the message was published to the hub.

Publishes all of the specified messages to the hub, returning whether they were published to the hub.

Subscribes to receive messages from the hub. The resulting subscription can be evaluated multiple times to take a message from the hub each time. The caller is responsible for unsubscribing from the hub by shutting down the queue.

Checks if the queue is empty.

Checks if the queue is at capacity.

Subscribes to receive messages from the hub. The resulting subscription can be evaluated multiple times within the scope to take a message from the hub each time.

The maximum capacity of the queue.

Checks whether the queue is shut down.

Shuts down the queue.

The current number of values in the queue.