Note the following code example creating an Observable
import { Observable } from 'rxjs';
let stream$ = Observable.create((observer) => {
observer.next(4);
})
create method takes a function with an input parameter observer.
An Observer is just an object with the following methods next error complete
observer.next(1);
observer.error('some error')
observer.complete();