These are chat archives for ReactiveX/RxJava

17th
Dec 2015
Leander Kurscheidt
@LeanderK
Dec 17 2015 13:28
is there a web framework, where the answer is decoupled from the request, so that i can have observable streams of the requests and zip some, map some and in the end answer them with the result
Abhinav Solan
@eyeced
Dec 17 2015 23:48
Hi all, I am trying this code
Observable.just(1, 2, 3, 4, 5, 6)
.groupBy(i -> i % 3)
.flatMap(o -> o.first())
.subscribe(System.out::println);
Now this should have just got me (1, 2, 3) as the result but it is giving
1
2
3
4
5
6
Dorus
@Dorus
Dec 17 2015 23:51
Possibly, first() unsubscribes so groupBy recreate the group?
Try .distinct(i -> i % 3) instead.
Abhinav Solan
@eyeced
Dec 17 2015 23:56
is that a bug ?
Dorus
@Dorus
Dec 17 2015 23:56
I'm not 100% sure. Let me test what Rx.Net does.
yup, Rx.Net gives 1,2,3 as expected.
I would suggest you fill a bug and see what the devs say about this. Seems fishy.
Abhinav Solan
@eyeced
Dec 17 2015 23:59
ok thanks