let observable = Rx.Observable

    .create(observer => {

        observer.next('S'); 

        observer.next('O');

        observer.next('V');

        observer.complete();

    })

observable.subscribe({

    next: (val) => console.log(val),

    error: (err) => console.log(err),

    complete: () => console.log('Complete !')

})