Фильтр наблюдаемых с использованием значений из других наблюдаемых

Question

У меня есть два наблюдаемые:

1. наблюдаемые, представляющих список входов флажка.
2. Наблюдаемое представление потока событий, поступающих с сервера.

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

Значения, полученные с сервера, включают в себя свойство tag, которое соответствует значениям в списке флажков. Наблюдаемое, полученное в результате комбинации указанных выше двух, приведет только к значениям от сервера, чье свойство tag включено в набор отмеченных флажков.

Answer 1

Вы можете использовать withLatestFrom. .

source.withLatestFrom(checkboxes, (data, checkbox) => ({data, checkbox})) 
    .filter(({data, checkbox}) => ...) 

Здесь checkboxes является наблюдаемым, представляющим список входов флажка. source является наблюдаемым, представляющим поток событий, поступающих с сервера. В функции фильтра вы можете проверить, действительно ли данные действительны по сравнению с настройками флажка и разрешить им прохождение.

Обратите внимание, что важно checkboxes излучает не менее 1 значения, прежде чем поток может испускать что-либо.

Ps. Что касается других ответов, это решение работает, даже если источником является cold.

Answer 2

По-видимому, мне нужна была комбинация select, filter и switchLatest. Я написал небольшой тестовый пример, демонстрирующий это: https://gist.github.com/igstan/d5b8db7b43f49dd87382#file-observable-filter-observable-js-L36-L45

Answer 3

Для того, чтобы фильтровать поток A с использованием значений потока B, вы должны наблюдать поток B и использовать последние значения для фильтрации потока А.

Использование switch() чтобы преобразовать B, наблюдаемые к наблюдаемым значениям образования от наблюдаемого A.

checkedInputValuesSource 
    .map(function (options) { 
     return dataSource 
      .filter(function (value) { 
       return options.indexOf(value) !== -1; 
      }); 
    }) 
    .switch() 
    .subscribe(function (x) { 
     console.log('out: ' + x); 
    }); 

Использование switch() предполагает, что dataSource является hot observable.

Пример использования interval() для получения фиктивных данных:

var input, 
 
    checkedInputValuesSource, 
 
    dataSource; 
 

 
input = document.querySelectorAll('input'); 
 

 
// Generate source describing the current filter. 
 
checkedInputValuesSource = Rx.Observable 
 
    .fromEvent(input, 'change') 
 
    .map(function() { 
 
     var inputs = document.querySelectorAll('input'), 
 
      checkedInputValues = []; 
 
     
 
     [].forEach.call(inputs, function (e) { 
 
      if (e.checked) { 
 
       checkedInputValues.push(e.value); 
 
      } 
 
     }); 
 
     
 
     return checkedInputValues; 
 
    }) 
 
    .startWith([]); 
 

 
// Generate random data source (hot). 
 
dataSource = Rx.Observable 
 
    .interval(500) 
 
    .map(function() { 
 
     var options = ['a', 'b', 'c']; 
 
    
 
     return options[Math.floor(Math.floor(Math.random() * options.length))]; 
 
    }) 
 
    .do(function (x) { 
 
     console.log('in: ' + x); 
 
    }) 
 
    .share(); 
 

 
checkedInputValuesSource 
 
    .map(function (options) { 
 
     return dataSource 
 
      .filter(function (value) { 
 
       return options.indexOf(value) !== -1; 
 
      }); 
 
    }) 
 
    .switch() 
 
    .subscribe(function (x) { 
 
     console.log('out: ' + x); 
 
    });

<script src='https://rawgit.com/Reactive-Extensions/RxJS/v.2.5.3/dist/rx.all.js'></script> 
 

 
<input type='checkbox' value='a'> 
 
<input type='checkbox' value='b'> 
 
<input type='checkbox' value='c'>

В этом примере будет производить вывод, подобный:

in: c 
in: a 
out: a 
in: b 
in: c 
out: a 
in: b 
in: a 

Где in отражает все генерируемые входные и b Данные, который пропускает фильтр. Фильтр настраивается путем проверки входов флажков, которые отражают значения «a», «b» и «c».