toStream

Converts an expression to an observable stream (a.k.a. TC 39 Observable / RxJS Observable). The provided expression is tracked by MobX as long as there are subscribers, automatically emitting when new values becomes available. The expressions respect (trans)actions.

Parameters

• expression
• fireImmediately (boolean): (default: false)

Returns

• IObservableStream<T>

Examples

const user = observable({
  firstName: "C.S",
  lastName: "Lewis"
})

Rx.Observable
  .from(mobxUtils.toStream(() => user.firstname + user.lastName))
  .scan(nameChanges => nameChanges + 1, 0)
  .subscribe(nameChanges => console.log("Changed name ", nameChanges, "times"))