Skip to main content
Module

x/rxjs/mod.ts>sequenceEqual

Deno port of RXJS
Latest
function sequenceEqual
import { sequenceEqual } from "https://deno.land/x/rxjs@v1.0.2/mod.ts";

Compares all values of two observables in sequence using an optional comparator function and returns an observable of a single boolean value representing whether or not the two sequences are equal.

Checks to see of all values emitted by both observables are equal, in order.

sequenceEqual subscribes to two observables and buffers incoming values from each observable. Whenever either observable emits a value, the value is buffered and the buffers are shifted and compared from the bottom up; If any value pair doesn't match, the returned observable will emit false and complete. If one of the observables completes, the operator will wait for the other observable to complete; If the other observable emits before completing, the returned observable will emit false and complete. If one observable never completes or emits after the other completes, the returned observable will never complete.

Example

Figure out if the Konami code matches

import { from, fromEvent, map, bufferCount, mergeMap, sequenceEqual } from 'rxjs';

const codes = from([
  'ArrowUp',
  'ArrowUp',
  'ArrowDown',
  'ArrowDown',
  'ArrowLeft',
  'ArrowRight',
  'ArrowLeft',
  'ArrowRight',
  'KeyB',
  'KeyA',
  'Enter', // no start key, clearly.
]);

const keys = fromEvent<KeyboardEvent>(document, 'keyup').pipe(map(e => e.code));
const matches = keys.pipe(
  bufferCount(11, 1),
  mergeMap(last11 => from(last11).pipe(sequenceEqual(codes)))
);
matches.subscribe(matched => console.log('Successful cheat at Contra? ', matched));

Parameters

compareTo: Observable<T>

The observable sequence to compare the source sequence to.

optional
comparator: (a: T, b: T) => boolean = [UNSUPPORTED]

Returns

A function that returns an Observable that emits a single boolean value representing whether or not the values emitted by the source Observable and provided Observable were equal in sequence.