RxJS version 5.x.x StreamAdapter for run(). - View it on GitHub