在Rxjs 6中重写Rxjs 4

Question

如何在Rxjs6中重写这个Rxjs4代码段？

const click$ = Rx.Observable.fromEvent($('.btn'), 'click').share();

click$
  .scan((a, b) => a + 1, 0)
  .bufferTime(4000, null, 3)
  .filter(buffer => buffer.length > 0)
  .concatMap(buffer => Rx.Observable.of(buffer).delay(1000))
  .timestamp()
  .subscribe(console.log);

https://jsbin.com/pacicubeci/1/edit?js,console,output

这是我的尝试：

import { $ } from "jquery";
import { Observable } from "rxjs";
import { bufferTime, filter, scan, concatMap, timestamp } from "rxjs/operators";

const click$ = Rx.Observable.fromEvent($(".btn"), "click").share();

click$
  .scan((a, b) => a + 1, 0)
  .bufferTime(1000, null, 3)
  .filter(buffer => buffer.length > 0)
  .concatMap(buffer => Rx.Observable.of(buffer).delay(1000))
  .timestamp()
  .subscribe(console.log);

https://angularjs-g8w7z9.stackblitz.io

Answer 1

我希望这就是你要找的

const click$ = fromEvent(document, "click").pipe(share());

click$
  .pipe(
    scan((a, b) => a + 1, 0),
    bufferTime(1000, null, 3),
    filter(buffer => buffer.length > 0),
    concatMap(buffer => of(buffer).pipe(delay(1000))),
    timestamp()
  )
  .subscribe(console.log);

运算符现在位于pipe中。

https://stackblitz.com/edit/angularjs-qczayg?file=app.js