Queries whether this has been marked as blocked, i.e., the owner of the list is waiting for new data.

Checks whether the queue currently has at least one element.

Returns an iterator to the dummy before the first element.

Returns a pointer to the dummy past the last element.

Removes all elements from the list.

implements our main loop for reading user input

Implements our main loop for reading user input.

Closes the publisher, eventually emitting on_complete on all observers.

Closes this queue and deletes all remaining elements. @warning Call only from the reader (owner).

@private

@copydoc local_actor::current_message_id

Delays execution of an action with a relative timeout. @param rel_time The relative time when this action should take place. @param what The action fo

Decreases the reference count of the coordinated and destroys the object if necessary.

Returns the raw pointer without modifying reference count and sets this to `nullptr`.