withoutclass
06/12/2018, 2:29 PMelizarov
06/12/2018, 3:05 PMwithoutclass
06/12/2018, 3:07 PMforEach
complement to consumeEach
, I’d be happy to put up a PR for it, but it seemed the thinking was that this is how JB would prefer the design to be to avoid confusion.elizarov
06/12/2018, 3:10 PMforEach
as a function that you can use invoke some suspending function on each element. We wanted to have it as extension on all the Rx streams, too, but Rx already has forEach
which only takes non-suspending function as parameter, so it was renamed to consumeEach
.withoutclass
06/12/2018, 3:10 PMelizarov
06/12/2018, 3:12 PMfor
loop does not consume the incoming channel makes it all really inconsistent. The question I’d ask here is whether we need to support for
loop at all. Maybe consumeEach
is the only operator we shall support (no for loops). for
loop support is a good blowback to Go (and just like in Go it does not consume anything), but I really question its value….withoutclass
06/12/2018, 3:15 PMdave08
06/12/2018, 3:45 PMelizarov
06/12/2018, 4:54 PMwithoutclass
06/12/2018, 5:03 PMBroadcastChannel
when any subscribers receives items?elizarov
06/12/2018, 5:14 PMdave08
06/12/2018, 5:16 PMproduce
...giso
06/12/2018, 7:01 PM