TOP

RxJS 实现摩斯密码(Morse) 【内附脑图】(二)
2019-08-15 00:10:06 】 浏览:296
Tags:RxJS 实现 密码 Morse

switchMap(n => { return of(n).pipe( // 只为了 Demo 演示中的展示用 tap(n => this.lastMorseGroupCharacters = n.join(' ')), // 转化成对应表中字符 map(this.translateSymbolToLetter), // 捕捉错误 catchError(n => { return of(morseCharacters.errorString); }) ) }) ) .subscribe(result => { // 输出最终转化结果 this.morseLog.push(result); console.log('结果:', result) });

四、解读 Michael Hladky 大神的示例

整体上,把 “嘀嗒” “短间隔” “长间隔” 都转化成替代符,过滤无用的替代符,然后 filter “长间隔” 替代符的流,来做 buffer 切片数据。其他还有因为使用 combineLatest 操作符导致的不同。

// 识别 “嘀” “嗒”
const morseCharFromEvents$ = observableCombineLatest(this.startEvents$, this.stopEvents$)
    .pipe(
        // 计算 mousedown mouseup 时间间隔
        map(this.toTimeDiff),
        // 转化成标识符
        map(this.msToMorseChar),
        // 过滤 Morse 单元组中的 “短间隔“ 标识符
        filter(this.isCharNoShortBreak as any)
    );

// 主信号流
this.morseChar$ = observableMerge(morseCharFromEvents$, this.injectMorseChar$)

// 识别 “长间隔“ 标识符,来作为切片流
const longBreaks$ = this.morseChar$
    .pipe(filter(this.isCharLongBreak as any));

// 切片成 Morse 单元组
this.morseSymbol$ = this.morseChar$
    .pipe(
        buffer(longBreaks$),
        map(this.charArrayToSymbol),
        filter(n => (n !== '') as any)
    )

// 错误处理 + 标识符对应表转化
this.morseLetter$ = this.morseSymbol$
    .pipe(
        switchMap(n => observableOf(n).pipe(this.saveTranslate('ERROR')))
    );

// Up 后补4个 “长间隔“ 标识符,用来做 Morse 单元组的结束
const breakEmitter$ = observableTimer(this.msLongBreak, this.msLongBreak)
    .pipe(
        mapTo(this.mC.longBreak),
        take(4)
    );
this.stopEventsSubject
    .pipe(
        switchMapTo(
          breakEmitter$.pipe(takeUntil(this.startEventsSubject))
        )
    )
    .subscribe(n => this.injectMorseChar(n));

总结

下图是读完《深入浅出RxJS》后的学习笔记,标注了一些操作符的快速记忆特点,方便使用的适合查阅。

 

image.png

 

本文作者:甄帅

文章来源:Worktile技术博客

欢迎访问交流更多关于技术及协作的问题。

文章转载请注明出处。

请关注公众号获取更多资料


RxJS 实现摩斯密码(Morse) 【内附脑图】(二) https://www.cppentry.com/bencandy.php?fid=91&id=228918

首页 上一页 1 2 下一页 尾页 2/2/2
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇Activity生命周期方法调用finish.. 下一篇R中的空间数据分析