subject-observer

2зной

1ответ

Реактивная Наблюдаемая Подписки: Прекратить подписку и продление подписки

У меня есть Наблюдаемая из BlockCollection, что я использую как очередь IObservable<ProcessHoldTransactionData> GetObservable() { _queue.GetConsumingEnumerable().ToObservable(TaskPoolScheduler.

c# system.reactive observable idisposable subject-observer 2017-01-15

---

0зной

1ответ

Angular2 маршрутизатор не меняет компонент

У меня есть 1 компоненты, который я хочу, чтобы повторно использовать для различных ссылок маршрутизаторов есть маршруты выглядеть: { path: '', component: OddComponent }, { path: 'sport/:id', compone

angular rxjs subject-observer 2016-10-17

---

1зной

1ответ

Angular2: rxjs Subject in Angular2 взаимодействие с родительским компонентом

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

angular typescript rxjs rxjs5 subject-observer 2016-12-06

---

1зной

2ответ

BehaviorSubject с логическим значением не работает как задуман

я реализовал простой BehaviorSubject, import {BehaviorSubject} from "rxjs"; class MyWeirdoClass { constructor() {} private st: Subject<boolean> = new BehaviorSubject<boolean>(null);

javascript angular rxjs behaviorsubject subject-observer 2017-01-31

---

0зной

1ответ

Получение текущего состояния в ngrx

Here - решение для получения текущего состояния в ngrx. Пример прост - вы просто используете take(1). Но в rxjs документации take он говорит: Возвращает указанное число подряд идущих элементов с начал

rxjs observable ngrx subject-observer 2017-01-31

---

0зной

1ответ

Запуск PublishSubject на другую тему rxJava

Я запускаю RxJava и создаю тему для использования onNext() метод для создания данных. Я использую Весна. Это моя установка: @Component public class SubjectObserver { private SerializedSubject<So

spring rx-java subject-observer 2016-10-25

---

2зной

1ответ

Как создать Observable из темы, не подвергая субъекта потребителям в RxJs v5

Я пытаюсь вернуть наблюдаемое из функции, которая использует Rx.Subject внутри. Конечно, как и с любым хорошим API, детали реализации должны быть полностью абстрагированы от потребителя. Однако, испол

javascript rxjs observable rxjs5 subject-observer 2016-12-21

---

3зной

1ответ

Angular2 - Rxjs Subject запускается дважды даже после отмены подписки

Я пишу настольное приложение с использованием углового2 и электрона, и есть функция загрузки. Мои DownloadService это import {Injectable} from '@angular/core'; import {Subject} from "rxjs"; interfa

angular rxjs subject-observer 2016-12-25

---