Rx Java Текучая доля - PullRequest
       21

Rx Java Текучая доля

0 голосов
/ 24 марта 2020

Почему share() не работает?

Flowable<Integer> flowable = Flowable.fromArray(1, 2, 3)
                .map(x -> {
                    System.out.println("-> " + x);
                    return x;
                }).share();
        flowable.subscribe(System.out::println);
        flowable.subscribe(System.out::println);

Текущий результат:

-> 1
1
-> 2
2
-> 3
3
-> 1
1
-> 2
2
-> 3
3

Ожидаемый результат:

-> 1
1
1
-> 2
2
2
-> 3
3
3
...