rxjs - 古い RxJS コードを v6 に変換する : merge、filter、timer、map、first、toPromise()

Question

このコードをバージョン 6 に更新しようとしていますが、フローを再処理する方法がわかりません。結果をパイプする必要があると思いますが、マージ、フィルター、タイマーのフローを使用してどのように実行できるかわかりません。 、マップ、最初に、以前は機能していた toPromise() です。私を教育したり、正しい方向に向けることができるRxJSの人々はいますか?

const chats: chats[] = <chats[]>await Observable.merge(
  this.chatService.$chats.filter(chats => chats.length > 0),
  Observable.timer(5000).map(x => { 
    throw 'Timeout'
  })
).first().toPromise()

if(chats.find( chat => chat.id === chatId )) {
  this.log.log(`Found active chat ${chatId}, navigating to it from push notification...`)                       
}

Answer 1

試す：

import { merge, timer } from 'rxjs';
import { filter, first, map, } from 'rxjs/operators';

const chats: chats[] = <chats[]> await merge(
  this.chatService.$chat.pipe(
    filter(chats => chats.length > 0),
  ),
  timer(5000).pipe(
    map(x => {
     throw 'Timeout';
   }),
  ),
 ).pipe(
  first(),
 ).toPromise();

 if(chats.find( chat => chat.id === chatId )) {
   this.log.log(`Found active chat ${chatId}, navigating to it from push notification...`)                       
 }

でチェーンする代わりに、演算子をパイプする必要があります.。