reactive-programming

0зной

1ответ

Почему последний вызов выполняется 3 раза?

У меня есть этот кусок кода, который вызывается из компонента: choose(n?: number): Observable<PickQuality[]> { var chosenObserver: Observer<PickQuality[]>; alert(n); // <-- Notice this line

1зной

1ответ

Странное поведение наблюдаемых # повторе в реактивных расширений

Я возиться с операторами гх и любопытно, почему just(null).repeat() не работает в качестве параметра для любой из встроенных операторов: Observable.interval(1, TimeUnit.SECONDS) .sample(Observabl

0зной

1ответ

Долговечность сообщения Lagom между постоянным субъектом и процессором чтения

просто задается вопросом о гарантии доставки уведомления о событиях от постоянного участника, полученного от источника, обработчику чтения в lagom, есть ли какая-либо или нет долговечности сообщения д

2зной

1ответ

Условно цепь наблюдаемого

Для следующей машинописи (с использованием rxjs): getRegularData(): Observable<MyData> { return WS.loadRegularData(); } getAlternateData(): Observable<MyData> { return WS.loadAlternateDat

0зной

1ответ

Query RxJava2 Db в другой предмет

В моем проекте Android я сильно полагаюсь на RxJava2, SqlBrite (с RxJavaInterop) и SqlDelight. У меня есть один поток RX, который должен идти бесконечно (пока мое обслуживание не прекратится), и на не

1зной

1ответ

Как собрать массив испущенных значений из Observable.from?

Так в Rxjs, у меня есть куча кода, return Observable.from(input_array) .concatMap((item)=>{ //this part emits an Observable.of<string> for each item in the input_array })

1зной

1ответ

Firebase отложенной загрузки с rxjs

У меня есть следующий код, чтобы получить последние CHAST сообщения: const pageSize = 10; this.notifier = new Subject<any>(); let last: Observable<any>; let infiniteList = Observable // Use