Moved ObservableStream and ObservableStreamWriter into Cogenity.IO