Описание тега rx-scala
RxScala - Реактивные расширения для Scala
1
ответ
Как использовать собственный планировщик в RxScala?
Я пытаюсь с val executors = Executors.newSingleThreadExecutor() val scheduler = Schedulers.from(executors) Observable.just[Int](1,2,3).subscribeOn(scheduler) вывести ошибку Error:(103, 43) type mismatch; found : rx.Scheduler required: rx.lang.scala.…
27 мар '16 в 03:06
1
ответ
Получаемые в будущем наблюдаемые обратные вызовы Scala не вызывают
Используя scala 2.11.7, rxscala_2.11 0.25.0, rxjava 1.0.16, мой oddFutures обратные вызовы не вызывают AsyncDisjointedChunkMultiprocessing.process(): package jj.async import scala.concurrent.Future import scala.concurrent.ExecutionContext import rx.…
15 ноя '15 в 04:16
1
ответ
Как соблюдать порядок обратной зависимости?
Я хотел бы наблюдать за деревом объектов в обратном порядке зависимости, но не знаю, какие комбинаторы использовать. В конкретном случае выполняется перебор ресурсов AWS для удаления, например, удаление объектов S3 перед удалением их блоков S3, напр…
28 июл '15 в 22:11
1
ответ
Вызов (перегруженный) функций RxJava из Scala
Я хотел создать Observable из массива Observable вот так: package rxtest import concurrent._ import concurrent.ExecutionContext.Implicits.global import rx.lang.scala._ import rx.lang.scala.JavaConversions._ import rx.lang.scala.schedulers._ object A…
14 апр '16 в 12:23
1
ответ
RxScala doOnCompleted не запускается после вызова.take()
Я новичок в RxScala Observables и испытываю странное поведение при использовании комбинации take(n) и doOnCompleted(). Ниже у меня есть пример теста, в котором я считаю, что первая подписка правильная (с take(2) в начале) и выводит все журналы для м…
26 апр '18 в 14:22
1
ответ
Поведение паразитного субъекта?
Возможно ли иметь вид BehaviorSubject с переключателями паузы и возобновления? Что-то вроде PausableBehaviorSubject.pause() а также PausableBehaviorSubject.resume()? Как это могло быть сделано? Идея состоит в том, что, когда пауза, субъект не будет …
30 май '16 в 15:20
2
ответа
Как создать одну наблюдаемую из другой
Допустим, у нас есть источник Observable of Ints: val source:Observable[Int] Я хотел бы создать другой Observable, производящий значения, чья разница с первым появившимся значением в источнике больше 10: def detect() = Observable[Int]( subscriber =&…
26 авг '16 в 18:48
1
ответ
Наблюдаемое противодавление в зависимости от дефицита ресурсов
В RxJava 1 / RxScala, как я могу регулировать / подавлять источник, наблюдаемый в следующей ситуации? def fast: Observable[Foo] // Supports backpressure def afterExpensiveOp: Observable[Bar] = fast.flatMap(foo => Observable.from(expensiveOp(foo))…
09 ноя '16 в 15:07
1
ответ
Опрос базы данных с использованием RxScala
TableEntries Я начинаю с RxScala и пытаюсь найти механизм опроса, который проверяет базу данных на каждый интервал (скажем, 20 секунд), чтобы проверить, не было ли каких-либо изменений в некоторых строках таблицы. object MyDatabaseService { def getA…
28 май '15 в 12:58
1
ответ
Тестирование rx-наблюдаемых из Futures/Iterables
Я имею: val observable: Observable[Int] = Observable.from(List(5)) и я могу проверить, что входной список действительно передается наблюдаемому, проверяя: materializeValues(observable) should contain (5) где materializeValues является: def materiali…
13 янв '18 в 11:01
1
ответ
Akka Streams - объедините последние операции
Я хотел бы объединить последние с Akka Streams, как описано здесь. Я не могу понять, как это сделать - пожалуйста, помогите! Спасибо, Райан.
19 окт '16 в 15:45
1
ответ
Почему `collect` заставляет наблюдателя не получать уведомлений?
Я использую rxscala и обнаружил очень тонкую проблему, и мой код упрощается следующим образом: import rx.lang.scala.Observable import rx.lang.scala.subjects.PublishSubject object SubtleBug extends App { case class Projects(projects: List[Project] = …
20 ноя '15 в 10:25
1
ответ
Как реализовать одноразовое использование заказанного ReplaySubject?
Как я могу иметь одного подписчика ReplaySubject тот: буферизует все события, полученные с onNext() пока кто-то не подпишется на него, как только кто-то подписывается на него, все буферизованные события пересылаются подписчику, стирая их из ReplaySu…
11 май '16 в 16:37
1
ответ
Как вы используете RxScala в Intellij Idea 14?
Я только недавно начал писать код в Scala, и я хочу начать работать с RxScala, но я не смог понять, как импортировать его в Intellij. Кто-нибудь знает, как это сделать, я провел последние несколько часов, пытаясь выяснить это, и я не ближе, чем когд…
29 июн '15 в 20:01
0
ответов
Наблюдаемые против будущей производительности
Я работаю с Vert.x 2.x ( http://vertx.io/), который широко использует асинхронные обратные вызовы. Они быстро становятся громоздкими с типичными проблемами ада вложенности / обратного вызова. Я рассмотрел как Scala Futures/Promises (который, я думаю…
20 мар '15 в 09:18
1
ответ
Преобразование Rx-Observables в Twitter-фьючерсы в Scala
Я хочу наиболее эффективно реализовать следующие функции. Они нужны мне для реализации биекций для автоматического преобразования между указанными типами. def convertScalaRXObservableToTwitterFuture[A](a: Observable[A]): TwitterFuture[A] = ??? def c…
10 янв '18 в 17:27
1
ответ
Как отменить сопоставленное Observable с указанием условия в RxScala/Java?
Исходная наблюдаемая ------a-------b-------c----------d-------->....нанесен на карту наблюдаемой -----A-------B(закончить)Простой код как это: val original = Observable.just('a', 'b', 'c', 'd') val mapped = original.map(x => x.toUpper) //how to l…
26 мар '16 в 06:09
1
ответ
Противодавление RxJava/RxScala с использованием запроса
У меня проблема с использованием противодавления RxJava. По сути, у меня есть один производитель, который производит больше элементов, чем может обработать потребитель, и хочет иметь некоторую буферную очередь для обработки только тех элементов, с к…
15 янв '16 в 18:04
2
ответа
RxScala: Как сохранить поток, выполняющий Observable.interval, живым?
Я пытаюсь написать простую программу 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 = Observab…
03 апр '15 в 21:21
1
ответ
Reactive Extensions (Rx) в Scala - выполнить метод через заданный интервал
Поскольку я довольно новичок в Reactive Extensions, мне было интересно узнать следующее. Используя Rx в Scala, я хочу иметь возможность вызывать метод, который извлекает контент из API каждую секунду. До сих пор я смотрел на операторы создания, испо…
01 дек '15 в 16:19