Вопросы по теме 'observable'
Каков пример непредвиденных последствий, возникающих из-за того, что Observable.merge‹'T› не является потокобезопасным?
В документации говорится:
«Для каждого наблюдателя зарегистрированный промежуточный объект наблюдения не является потокобезопасным. То есть наблюдения, возникающие из источников, не должны запускаться одновременно в разных потоках».
Это...
185 просмотров
schedule
07.11.2022
Ссылка на предыдущие элементы. Есть ли какое-либо наблюдаемое расширение для этого в Rx или Rxx?
У меня есть IObservable, я ищу способ сделать что-то подобное
var referenceBack2 = source.Ref(2);
скажем, у меня есть эта последовательность в источнике
A-B-C-D-E-F-G-H
ReferenceBack2 не будет выполнять OnNext() для A до тех пор, пока B...
60 просмотров
schedule
17.11.2023
Привязка Knockout js не обновляется
У меня есть модель представления, которая содержит ссылку на другой объект, и указанный объект привязан к моему пользовательскому интерфейсу. Привязки, кажется, работают нормально, когда я добавляю объекты в наблюдаемый массив, но, похоже, не...
1007 просмотров
schedule
06.06.2024
Как абстрагироваться от оборудования с помощью RXJava и Observables без субъектов?
Я работаю над проектом, в котором у меня есть аппаратное устройство, разговаривающее с моим Android-приложением через USB-кабель. Буферы протокола, завернутые в тонкий слой сериализации, — это мой протокол связи.
В настоящее время связь USB...
347 просмотров
schedule
19.01.2024
Наблюдается для пакетной обработки, например, Lmax Disruptor
Те, кто знаком с кольцевым буфером lmax (disruptor) , знают, что одно из самых больших преимуществ этого Структура данных заключается в том, что она группирует входящие события, и когда у нас есть потребитель, который может воспользоваться...
707 просмотров
schedule
16.11.2023
Как запустить 2 запроса последовательно в Android RxJava Observable?
Я хочу запустить 2 асинхронных задачи, одну за другой (последовательно). Я что-то читал про ZIP или Flat, но не очень понял...
Моя цель - загрузить данные из локального SQLite, а когда он завершится, он вызовет запрос на сервер (удаленный)....
13268 просмотров
schedule
07.11.2022
RxJs Observable: выполнить функцию, если она пуста/отфильтрована
У меня есть Observable, который слушает пользовательский ввод из текстового поля. Если длина наблюдаемой строки >=3 ( filter ), выполняется некоторый HTTP-вызов ( switchMap ).
Теперь я хотел бы как-то определить, был ли отфильтрован...
14082 просмотров
schedule
31.10.2023
Android — наблюдаемый список
Есть ли какой-либо наблюдаемый список в Android? ObservableList класс не существует! Я хочу иметь список, который, если произошли какие-либо изменения элемента, уведомит меня об обновлении представлений.
Примечание. Если нативного способа...
740 просмотров
schedule
22.12.2023
Rx.Observable.prototype.skip не определен
У меня есть приложение Angular 2 со следующим кодом:
nextPage() {
this.currentPage += 1;
this.files = this._rawFiles
.skip((this.currentPage - 1) * 100)
.take(100);
}
Он возвращает следующую ошибку:
ORIGINAL...
499 просмотров
schedule
15.06.2024
Реактивный — сочетание наблюдаемого интервала с ручными триггерами
У меня есть Observable.Interval(TimeSpan.FromSeconds(1)) и подписчик, который каждый раз что-то проверяет в БД. Но иногда, когда я делаю эту проверку из БД, я хочу немедленно выполнить другую проверку (снова вызвать этого подписчика, потому что я...
1653 просмотров
schedule
18.01.2024
Typescript / Angular2: приведение JSON к взаимодействию с Observable и JSONP
Я бы хотел передать свой json-массив своему интерфейсу, который я создал, и отображать его в браузере. Я думаю, что, вероятно, что-то не так с моим интерфейсом, но я не могу этого понять ... Что мне нужно изменить, чтобы мой код заработал?...
15247 просмотров
schedule
02.09.2022
Обертывание EnumMap в наблюдаемом SimpleMapProperty
Мне нужно добавить SimpleMapProperty в класс обслуживания JavaFX, но я не уверен в правильности синтаксиса, если я использую правильный подход. Обратите внимание, что я не пытаюсь сделать так, чтобы служба JavaFX выглядела как Java Bean, мне просто...
175 просмотров
schedule
17.11.2022
Конец излучения RxJava Observable.Interval
Я хотел бы иметь повторяющуюся наблюдаемую, которая испускает элементы, пока какое-то условие не сбудется. Затем он вызывает onComplete и заканчивает излучение.
Я думал, что что-то вроде этого будет работать, но я ошибаюсь:
return...
762 просмотров
schedule
14.01.2024
Предполагается ли, что прокси-сервер JavaScript перехватывает прямые изменения базового объекта, такого как Object.Observe?
MDN для Object.Observe говорит что Observe теперь устарел, и вместо этого мы должны использовать «более общий объект Proxy».
Но Observe позволяет перехватывать изменения на существующем объекте. Если Proxy не позволяет, то Proxy API не является...
483 просмотров
schedule
18.05.2024
размер стека вызовов превышен при использовании выборки с наблюдаемым сокращением
Я использую выборку, как показано здесь ( Используйте выборку вместо ajax с избыточностью -observable ), чтобы выполнить выборку на стороне сервера с помощью node. К сожалению, AjaxObservable работает только в браузере, поэтому я использую...
262 просмотров
schedule
05.10.2023
При ошибке переключиться на другой наблюдаемый после хотя бы одного успешного ответа
Я использую Observables of rxjs для связи с устройством, доступным через HTTP. HTTP-вызовы запускаются до того, как устройство полностью подключится к сети, поэтому некоторые вызовы могут быть неудачными в начале. В какой-то момент устройство...
226 просмотров
schedule
28.05.2024
Angular 2 Http, Observables и рекурсивные запросы
У меня есть конечная точка REST, которая возвращает список элементов, максимум 1000 элементов за раз. Если элементов больше 1000, ответ имеет HTTP-статус 206 и заголовок Next-Range , который я могу использовать в следующем запросе для получения...
10182 просмотров
schedule
14.02.2024
Сопоставьте ошибки с наблюдаемыми с помощью C # ReactiveX
У меня есть наблюдаемое MyObservable<Object> , которое может бросить CustomExceptions где
private class CustomException : Exception
Что я хочу сделать, так это преобразовать CustomExceptions в объекты и испустить их в новом...
381 просмотров
schedule
23.08.2022
Angular 2 дублированная подписка в компоненте
Есть ли способ избежать дублирования подписки на behaviorSubject в компоненте, кроме отказа от подписки на него в ngOnDestroy? Пока что это единственный способ избежать дублирования подписки при перемещении вперед и назад по компоненту, в котором я...
3533 просмотров
schedule
11.02.2024
Angular2 Observable с RxJS без ошибок, но событие не запускается
Я создаю текст простого типа ввода с объектом Observable, связанным с событием keyup.
Я использую Angular2 final ("@angular/core": "~ 2.1.1" с "rxjs": "5.0.2").
Вот мой app.component.ts:
import {Component} from '@angular/core';
import...
232 просмотров
schedule
10.01.2024
