Rxチャーハン

recipe.js

import {Observable, Subject} from 'rxjs'

// # 材料
// ## ご飯
class ご飯 {
  freeze() {
    this.温度 = -10
    return this
  }

  cool() {
    this.温度 = 4
    return this
  }

  heat() {
    this.温度 = 45
    return this
  }
}

const 冷やご飯 = new ご飯().cool()

// ## 具
class 刻みネギ {}
class 刻みベーコン {}

const 長ネギ = [new 刻みネギ(), new 刻みネギ(), new 刻みネギ(), new 刻みネギ()]
const ベーコン = [new 刻みベーコン(), new 刻みベーコン(), new 刻みベーコン()]

// ### 卵を実装する
const 黄身 = new Observable((observer) => {
  observer.next(18)
  observer.complete()
})
const 白身 = new Observable((observer) => {
  observer.next(36)
  observer.complete()
})

const 卵 = Observable.merge(黄身, 白身)

// ## 調味料
class 調味料 {
  constructor(種類) {
    this.調味料$ = new Subject()
    this.種類 = 種類
  }

  sprinkle() {
    this.調味料$.next(this.種類)
  }

  prepare() {
    return this.調味料$
  }
}

const 塩 = new 調味料('塩')
const コショウ = new 調味料('コショウ')
const 醤油 = new 調味料('醤油')
const 鶏ガラスープ = new 調味料('鶏ガラスープ')

// ## 具材を加工する
const 刻まれたネギ = Observable.from(長ネギ)
const 刻まれたベーコン = Observable.from(ベーコン)

const 溶き卵 = 卵.scan((acc, val) => acc + val).last()

const チンご飯 = new Observable((observer) => {
  observer.next(冷やご飯)
  observer.complete()
}).delay(30 * 1000)
  .map((ご飯30秒後) => {
    return ご飯30秒後.heat()
  })

// ## フライパンを火にかける
const フライパン = Observable
  .interval(1000)
  .do((v) => {
    console.log(`
 ∧,,∧
(；\`・ω・）　　｡･ﾟ･⌒） チャーハン作るよ！！
/　　 ｏ━ヽニニフ))
しー-Ｊ
    `)
  })
  .publish()

フライパン.connect()

// ## 炒める
const ごま油 = new 調味料('ごま油')

const チャーハン = フライパン
  .merge(ごま油.prepare())
  .merge(刻まれたベーコン)
  .merge(刻まれたネギ)
  .merge(塩.prepare())
  .merge(コショウ.prepare())
  .merge(溶き卵)
  .merge(チンご飯)
  .merge(醤油.prepare())
  .merge(鶏ガラスープ.prepare())

// たぶん小さじ1はこれくらい
ごま油.sprinkle()
ごま油.sprinkle()
ごま油.sprinkle()
ごま油.sprinkle()

塩.sprinkle()
コショウ.sprinkle()
塩.sprinkle()
コショウ.sprinkle()

醤油.sprinkle()
醤油.sprinkle()
鶏ガラスープ.sprinkle()
塩.sprinkle()
コショウ.sprinkle()

class ぼく {
  eat(食べ物) {
    食べ物.subscribe(() => {
      console.log('おいしい！')
    })
  }
}

new ぼく().eat(チャーハン)

sprinkle() が独立してるので、subscribeの前に終了してしまいますね