`basic-compose` example

import compose from '../'
import log from './console'
import { map, take, tap } from 'rxjs/operators'
import { interval } from 'rxjs/observable/interval'
import { Observable } from 'rxjs/Observable'

interval(1000).pipe(
  take(5),
  tap(log('input:')),
  compose,Observable>(
    map((s: string) => `${s.length}${s}`),
    map((x: number) => '.'.repeat(x)),
    map((x: number) => 4 - x)
  )
)
.subscribe(log('output:'), log('error:'), log('done'))