Use an Rx observable and the rx pipe as in Rob Wormald's http://embed.plnkr.co/wj4lRtAwNMry8ToNzLrm/preview