File tree 1 file changed +0
-6
lines changed
1 file changed +0
-6
lines changed Original file line number Diff line number Diff line change @@ -205,12 +205,6 @@ We have two of them in this code and that is why we see "Begin" printed twice.
205
205
In Rx lingo this is called a _ cold_ publisher. Many standard Rx operators produce cold streams, too. We can collect
206
206
them from a coroutine, and every collector gets the same stream of elements.
207
207
208
- ** WARNING** : It is planned that in the future a second invocation of ` consumeEach ` method
209
- on an channel that is already being consumed is going to fail fast, that is
210
- immediately throw an ` IllegalStateException ` .
211
- See [ this issue] ( https://github.com/Kotlin/kotlinx.coroutines/issues/167 )
212
- for details.
213
-
214
208
> Note that we can replicate the same behaviour that we saw with channels by using Rx
215
209
[ publish] ( https://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Flowable.html#publish() )
216
210
operator and [ connect] ( https://reactivex.io/RxJava/2.x/javadoc/io/reactivex/flowables/ConnectableFlowable.html#connect() )
You can’t perform that action at this time.
0 commit comments