# Observer

Follow me on Twitter, happy to take your suggestions on topics or improvements /Chris

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();