-record(stream_error, {error_type :: binary(), message :: binary()}).