reactive-streams

0зной

1ответ

Невозможно использовать recivestream Абонент с источниками потока akka

Я пытаюсь подключить абонента реактивированного потока к источнику akka. Мой источник, кажется, работает нормально с простой раковиной (например, foreach) - но если я положил реальную раковину, сделан

2зной

1ответ

Потоки Akka и границы транзакций

Я все еще понимаю концепции потока Akka и пытаюсь понять, как их сопоставить с сценариями, когда у нас есть коллекция элементов, которые нужно обрабатывать атомным способом. Допустим, у нас есть заказ

0зной

1ответ

Использование процессора реактивных потоков с RxJava 2.0

У меня есть org.reactivestreams.Processor, который я бы хотел использовать с RxJava 2.0. Однако, хотя есть преобразования для интеграции org.reactivestreams.Publisher с RxJava, например io.reactivex.F

8зной

1ответ

Akka Streams: Что представляет Мать в Source [out, Mat]

В потоках Akka, что означает Mat in Source [Out, Mat] или Sink [In, Mat]. Когда это будет фактически использовано?

1зной

1ответ

Предоставление реактивной api в базе данных

Как предоставить реактивный поток api для db, который не поддерживает потоковое вещание? Например, давайте скажем, например, dynamodb. При вызове get dynamodb собирается вернуть все результаты. Таким

1зной

1ответ

Akka Потоки фильтра и группы путем на коллекции ключей

У меня есть поток case class Msg(keys: Seq[Char], value: String) Теперь я хочу, чтобы фильтровать для подмножества ключей, например, val filterKeys = Set[Char]('k','f','c') и Filter(k.exists(filterK

3зной

1ответ

Способы поддержания противодавления в потоках Akka с участием нескольких JVM

Мне известно, что с Akka 2.4.16 не существует «удаленной» реализации реактивных потоков. Спецификация фокусируется на потоке, запущенном на одной JVM. Однако, рассматривая прецедент для использования