0
ответов

Как охотно объединить два Flux?

Флюс & л; Длинные > flux1 = Flux. < Long > create (fluxSink -> {for (long i = 0; i < 20; i ++) {fluxSink.next (i);}}) .filter (...
вопрос задан: 3 March 2019 10:09
0
ответов

В проектном реакторе или потоках Акки, в чем концептуальная разница между потребителем и подписчиком?

Понятия приемника и подписчика кажутся мне похожими. Кроме того, я не вижу, чтобы концепция стока была явно определена в спецификации реактивных потоков.
вопрос задан: 9 January 2018 06:27