import { Subject } from 'rxstream';
 
let stream$ = new Subject();
stream$.subscribe(value => console.log(value));
stream$.next(1); // 1
stream$.next(2); // 2

import { Subject } from 'rxstream/es5/subjects/subject';
import { merge } from 'rxstream/es5/operators/merge';