Helper to construct a Stream, useful if the Stream you are modeling has a blocking loop
See Implementation
Helper to construct a Stream, useful if the Stream you are modeling has a blocking loop