Shim over RxJS methods #37
Description
Allow the following:
let s = gustav.createWorkflow()
.source('intSource')
.map(item => item * 2)
.sink('console', 'demo');(There may be something to extending the Observable class here)
{{ message }}
Allow the following:
let s = gustav.createWorkflow()
.source('intSource')
.map(item => item * 2)
.sink('console', 'demo');(There may be something to extending the Observable class here)