Rxjs

事件流

import { range } from "rxjs";
import { map, filter } from "rxjs/operators";
 
range(1, 200)
  .pipe(
    filter(x => x % 2 === 1),
    map(x => x + x)
  )
  .subscribe(x => console.log(x));

import { Subject, from } from "rxjs";
import { debounceTime, distinctUntilChanged, switchMap } from "rxjs/operators";

const searchItems = new Subject();

searchItems
    .pipe(
        debounceTime(300),
        distinctUntilChanged(),
        switchMap((val) => from(getSuggestList(val)))
    )
    .subscribe((x) => console.log(x));

const input = document.getElementById("input");

input.oninput = search;

function search(val) {
    searchItems.next(val.target.value);
}

function getSuggestList(val) {
    return new Promise((resolve) => {
        console.log(val);
        setTimeout(() => {
            resolve([
                { id: 1, name: "zhangsan" },
                { id: 2, name: "lisi" },
            ]);
        });
    });
}

lodash