RxJS запускает функцию выбора только один раз

Question

RxJS запускает функцию выбора только один раз

1

Я использую combLatest, который можно наблюдать с двумя потоками и функцией выбора.

const todos = Rx.Observable.of([{
  id: 1,
  completed: false,
  text: 'one'
}, {
  id: 1,
  completed: true,
  text: 'two'
}]);

const filter = Rx.Observable.of('SHOW_ALL');


const getTodos = Rx.Observable.combineLatest(todos, filter, (todos, filter) => {
  console.log('calculation');
  // doing some calculation...
  return todos;
});

getTodos.subscribe(console.log)
getTodos.subscribe(console.log)

<script src="https://unpkg.com/@reactivex/[email protected]/dist/global/Rx.js"></script>

Мне нужно, чтобы селектор результатов запускался только один раз для обоих абонентов, чтобы избежать перерасчета. Например, что-то вроде кэша, результат и дайте мне последнее значение, если ни один из входов не изменится.

Есть ли способ сделать это с помощью RxJS?

undefined 02 июнь 2017, в 09:34

Источник

Теги:

javascript

rxjs

1 ответ

Ещё вопросы

atomrc · Accepted Answer · 2017-06-02T06-22-00.000Z

Я думаю, вы ищете оператора shareReplay. Это позволяет вам делиться стоимостью, производимой вашим combineLatest между всеми подписчиками. https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/sharereplay.md

Возможно, вам захочется взглянуть на replay если вы не хотите, чтобы автоматическое соединение/отсоединение, когда абонент переходил от 0 до 1 или более, и наоборот. https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/replay.md

const getTodos = Rx.Observable.combineLatest(todos, filter, (todos, filter) => {
  console.log('calculation');
  // doing some calculation...
  return todos;
})
.shareReplay();

Вот пример:

const todos = Rx.Observable.of([{
  id: 1,
  completed: false,
  text: 'one'
}, {
  id: 1,
  completed: true,
  text: 'two'
}]);

const filter = Rx.Observable.of('SHOW_ALL');

const getTodos = Rx.Observable.combineLatest(todos, filter, (todos, filter) => {
  console.log('calculation');
  // doing some calculation...
  return todos;
})
.shareReplay();

getTodos.subscribe(console.log.bind(console))
getTodos.subscribe(console.log.bind(console))

<script src="/rx.lite.js"></script>

Я получаю эту ошибку: Rx.Observable.combineLatest (...). ShareReplay не является функцией
shareReplay доступен с версии RxJS 5.4.0. Скорее всего, у вас более старая версия.
Да неужели!!! Нет, он также доступен в RxJS4 (документ, который я связал, взят из документов v4)
@martin Это на самом деле в Rx , так как V2.3.1 github.com/Reactive-Extensions/RxJS/blob/v2.3.1/doc/api/core/... Я думаю , вы не используете такую старую версию
Вот рабочий пример с shareReplay jsbin.com/cafasunife/edit?html,js,console,output Как вы можете видеть, есть 2 подписчика и 2 события и только 2 журнала calculation
Это должен быть один расчетный журнал, а не дважды.
Это правильный оператор в Rx версии 5 .publishReplay (1) .refCount ()
@atomrc RxJS 5 - это полное переписывание RxJS 4, и некоторые операторы были добавлены позже. Если вы мне не доверяете, потребуется около 30 shareReplay() чтобы проверить это самостоятельно в журнале изменений, который shareReplay() был добавлен 2017-05-09 github.com/ReactiveX/rxjs/blob/master/…
@martin Ну, я не знал, что они shareReplay удалили shareReplay между v4 и v5. Я знал, что это было полное переписывание, хотя :) Может быть, если вопрос о rxjs5 , op должен добавить его в качестве тега или в описании?
@undefined ваш поток todo генерирует 2 значения, поэтому вы обязательно должны выполнить combineLatest вызов combineLatest дважды (как минимум). Если вам нужно только 1 значение, вы можете искать оператор filter , но я думаю, это не то, что вы хотите сделать. Что делает shareReplay , так это то, что combineLatest вызывается только один раз для всех абонентов.