textEntry.js

import {Observable} from 'rx';

export function textEntryIntentWithSendButtonClicked(DOMSource) {
  const textStream$ = DOMSource.select('#input-msg').events('keyup').map(e => e.target);
  const buttonClick$ = DOMSource.select('#send-btn').events('click').map(e => e.target);

  return {textStream$, buttonClick$};
}

export function textEntryIntentWithEnterKeyPressed(DOMSource) {    
  const textStream$ = DOMSource.select('#input-msg').events('keyup').filter(textStream => textStream.keyCode !== 13).map(e => e.target);
  const enterKeyPressed$ = DOMSource.select('#input-msg').events('keyup').filter(textStream => textStream.keyCode === 13).map(e => e.target);
  
  return {textStream$, enterKeyPressed$};
}
...