Почему 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