-record(stream_exhausted, {stream_name :: binary()}).