Shared streams implemented with tests