import { Observable as RxStream } from '@reactivex/rxjs/dist/package/Observable'; import '@reactivex/rxjs/dist/package/add/operator/map'; import '@reactivex/rxjs/dist/package/add/operator/merge'; import '@reactivex/rxjs/dist/package/add/operator/mergeMap'; import '@reactivex/rxjs/dist/package/add/operator/scan'; import '@reactivex/rxjs/dist/package/add/operator/catch'; import '@reactivex/rxjs/dist/package/add/operator/filter'; import '@reactivex/rxjs/dist/package/add/observable/empty'; import '@reactivex/rxjs/dist/package/add/observable/from'; import '@reactivex/rxjs/dist/package/add/observable/of'; import '@reactivex/rxjs/dist/package/add/observable/fromPromise'; import '@reactivex/rxjs/dist/package/add/observable/combineLatest'; declare module '.' { interface S_ { 'RxStream': RxStream; } } declare module '../fantasy/typeclasses' { interface _ { 'RxStream': RxStream; } }