Чем отличается использование перечислителей, итераций и перечислителей Play Frameworks с использованием RxScalas Observables, подписок и т. Д. Для асинхронных потоков данных? В каком типе сценариев вы бы выбрали RxScala и когда выбрали бы Play?...

В настоящее время у меня есть следующий код: def method(): Future[State] = Future { // some processing State.Completed } Но теперь я заметил, что на самом деле хочу вместо этого «опубликовать» набор промежуточных состояний: def...

Из документов API Rx Observable в scala: http://reactivex.io/rxscala/scaladoc/#rx.lang.scala.Observable Существует два метода применения: один принимает подписчика, а другой — наблюдателя. В чем разница между этими двумя методами применения,...

У меня есть Observable, который подключается к службе через протокол Socket. Подключение к сокету происходит через клиентскую библиотеку. В клиентской библиотеке, которую я использую, есть java.util.Observer, с помощью которой я могу...

Я пытаюсь написать простую программу RxScala: import rx.lang.scala.Observable import scala.concurrent.duration.DurationInt import scala.language.{implicitConversions, postfixOps} object Main { def main(args: Array[String]): Unit = { val o...

Когда у вас есть большой наблюдаемый граф (т. е. наблюдаемый, составленный много раз с использованием merge , groupBy , join и т. д.), и возникает исключение, иногда трудно понять, откуда возникло исключение. Я хотел бы знать, можно ли узнать,...

Есть ли способ использовать и RxJava , и RxScala в одном проекте? import rx.lang.scala.{Observable => ScalaObservable} import rx.{Observable => JavaObservable} У нас есть модуль, написанный на Java, который использует JavaObservable...

Я пишу небольшое приложение JavaFx на Scala, и мне нравится использовать для этого RxScala и RxJavaFx. С помощью следующего кода я получаю RxJava Observable : JavaFxObservable.fromObservableValue(textfield.textProperty()) Очевидно,...

Скажем, у меня есть две наблюдаемые отсортированных двойников. Я хотел бы получить разницу между ними как наблюдаемую. Например: 1 2 4 left: ──o───────o───────────o────/ 1 3 4 5 right:...

Я новичок в RxScala Observables и испытываю странное поведение при использовании комбинации take(n) и doOnCompleted(). Ниже у меня есть пример теста, в котором я считаю, что первая подписка верна (с take(2) в начале) и выводит все журналы для...

Как мне отобразить список наблюдаемых в Outwatch ? Что, если мне нужен один Observable: как мне упорядочить/заархивировать их как аппликативный? Ожидается ли, что он будет отображаться, когда я использую аппликативную (?) операцию «zip» для...

У меня есть код, который вызывает cockbase для получения некоторых строк следующим образом: val gotValues: Observable[JsonDocument] = Observable.from(rowKeys).flatMap(id => couchbaseBucket.async().get(id)) Если у меня есть...

У меня есть входящие запросы на обработку, из которых я не хочу, чтобы слишком много обрабатывалось одновременно из-за истощения общих ресурсов. Я также предпочел бы, чтобы запросы, которые имеют общий уникальный ключ, не выполнялись одновременно:...

У меня есть список наблюдаемых obs1, obs2, obs3,..., Каждый из них может выдавать несколько элементов (из базы данных mongodb), меня интересуют только первые N элементов. Я хочу убедиться, что запросы моих наблюдаемых выполняются только в случае...