[Streams API] Error storage should be moved from source to stream/reader