scala - rx Observable の作成後に要素を追加する

Question

Observable の作成後に要素を追加したい場合、シナリオを実装するにはどうすればよいですか? オブザーバー パターンでは、イベントを発生させるだけです。何かアイデアはありますか？

import rx.lang.scala._

val target  = Observable(1,2,3,4)

val subscription1 = target subscribe(println(_))
val subscription2 = target subscribe(println(_))


def addToObservable(toAdd: Int, target: Observable[Int]): Observable[Int] = {
  target/*.addElementAndNotifyObservers(toAdd)*/
}

addToObservable(4, target) //should print 4 on all subscriptions
addToObservable(6, target) //should print 6 on all subscriptions