Mutator-io pipe example

pipe.ts

import { Observable } from 'rxjs'
import {
  MutatorIO,
  InputStream,
  OutputStream
} from 'mutator-io'
const myPipe = {
  name: 'myPipeName',
  in: {
    create: () => Observable.of('My message', 'My other message')
  } as InputStream,
  out: {
    create: () => (msg) => console.log(`Message arrived: ${msg}`)
  } as OutputStream,
} as MutatorIO.Pipe