代码之家 › 专栏 › 技术社区 › gka

将流与RXJS(带交换机映射和Take)结合在一起

observable rxjs

gka · 技术社区 · 7 年前

我有两个流,来自键盘事件(k)和鼠标事件(m)。当上一个事件为空或鼠标事件时,应生成键盘事件。当上一个事件是键盘事件时,应生成鼠标事件。

所以调度m-k-m-k-k-m-k-k,应该调用键盘处理程序3次,鼠标处理程序2次。

以下订阅允许键盘流生成多个键盘事件,这不是我想要的。

keyboardStream(document)
        .do(keyboardHandler)
        .switchMap(() => mouseStream(document).take(1))
        .subscribe(mouseHandler)

1 回复 | 直到 7 年前

gka 7 年前

我的结尾是:

const keyboard$ = fromEvent(document, 'keyup')
.pipe(
    mapTo('k')
);

const mouseOnce$ = fromEvent(document, 'keyup')
    .pipe(
        switchMap(() => fromEvent(document, 'mousedown').pipe(first())),
        mapTo('m')
    );

const stream = merge(
    mouseOnce$,
    keyboard$
).pipe(distinctUntilChanged());

推荐文章

Ole · 在使用新的Angular Resource API时取消搜索术语?

8 月前

koque · 为什么我的RxJs主题没有按预期工作?

8 月前

Raphaël VO · 不使用Observable的初始值

8 月前

xarielah · 从app.config.ts调用时,BehaviorSubject不会更新

1 年前

Lenni · 返回信号并在Angular中订阅它

1 年前

dman · 在Angular单元测试中似乎无法模拟行为主体

1 年前

Nevyan Dimitrov Neykov · 效果内部的角度信号()

1 年前

Ð¤ÐµÐ´Ñ Ð Ð°Ð²ÑÐµÐµÐ² · 如何在react-js中使用Date()在后台增加变量?

1 年前

Ryley38 · 如何跳过流的第一个值,除非它是RxJS的复制粘贴?

1 年前

techwestcoastsfosea · Angular 18-RxJS:Subscribe已弃用[重复]

1 年前