code: function model(inputValue$, messages$) {
      return Rx.Observable.combineLatest(
        inputValue$.startWith(null),
        messages$.startWith([]),
        (inputValue, messages) => ({ messages, inputValue })
      )
    }
docs: Model takes our action streams and turns them into the stream of app states