+ Stream.take(time, unit, timer?) to complete after a given time where timeout() returns an error signal
+ Controls.block() to block a consumer until complete or error
+ Controls.isPublishing() to test if an action is still accepting signals from its publisher