Synchronous message receiving.
returns a message source connected to the sink created by
a call to
. If no such sink exists, an
exception is thrown.
Synchronously reads a message from a source (i.e. it blocks if there is currently no message available).
Returns a lazy list of all messages arriving at a source (like
Disconnects from a message sink. The detached source becomes invalid and must not be used again.
Helper function to simplify resource handling.
creates a source, calls
withSource tag body
body, then disconnects the source, even if
body throws an exception.