Блог

У меня есть, BehaviorSubject что я хотел бы иметь возможность filter , но поддерживать качество, подобное поведению субъекта, чтобы новые подписчики всегда получали значение при подписке, даже если последнее переданное значение было отфильтровано. Есть ли краткий способ сделать это, используя встроенные функции из rxjs? Например:

 const isEven = (n) => n % 2 === 0;
const source = new BehaviorSubject(1);
const stream = source.pipe(filter(isEven));
stream.subscribe((n) => console.log(n)); // <- I want this to print `1`
source.next(2); // prints `2`; that's good
source.next(3); // does not print anything; that's good
  

Я написал свою собственную реализацию, но предпочел бы более простое решение с использованием существующих операторов вместо этого, если это просто.

Просто используйте второй объект BehaviorSubject

 const { BehaviorSubject } = rxjs;
const { filter} = rxjs.operators;

const isEven = (n) => n % 2 === 0;
const source = new BehaviorSubject(1);
const stream = new BehaviorSubject(source.getValue());

source.pipe(filter(isEven)).subscribe(stream);

stream.subscribe(val => { console.log(val); });
source.next(2);
source.next(3);  

 <script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.4.0/rxjs.umd.min.js"></script>  

Ответ Адриана заслуживает похвалы, похоже, что он отвечает наилучшим образом, учитывая встроенные операторы, доступные с rxjs самим собой. Это не совсем соответствовало моим потребностям, поэтому я опубликовал свой пользовательский оператор в своей маленькой библиотеке s-rxjs-utils . Это он вызвал filterBehavior() . Из документов:

Работает аналогично filter() , но всегда пропускает первую эмиссию для каждого нового подписчика. Это делает его подходящим для подписчиков, которые ожидают, что observable будет вести себя как BehaviorSubject , где первое излучение обрабатывается синхронно во время вызова subscribe() (например, async канал в шаблоне Angular).

Ваш stream уже передан для использования isEven фильтра, поэтому ваше начальное значение 1 не отображается в вашей консоли, ведет себя так, как ожидалось.

Если вы хотите увидеть свое начальное значение, равное 1, подпишитесь непосредственно на BehaviourSubject :

 const isEven = (n) => n % 2 === 0;
const source = new BehaviorSubject(1);
const stream = source.pipe(filter(isEven));

// should print 1, and should print 2 and 3 when your source is nexted.
source.subscribe((n) => console.log(n)); 

stream.subscribe((n) => console.log(n)); // <- should NOT Print 1, because it has been filtered
source.next(2); // prints `2`; that's good
source.next(3); // does not print anything; that's good