ObservableStream related code prettifies have been done.