Using Observable.create() - Coding Blast - www.codingblast.com

observable-create.ts

import { Observable } from 'rxjs';

interface ISimpleObserver<T> {
    next: (value: T) => void;
    error: (err: any) => void;
    complete: () => void;
}

let words = ['coding blast', 'coding', 'blast'];

let source = Observable.create(function onSubscription(observer: ISimpleObserver<string>) {
    for (let word of words) {
        observer.next(word);
    }

    observer.complete();
});

source.subscribe(next, error, complete);

function next(value: any) {
    console.log('next: ', value);
}

function error(err: any) {
    console.log('error: ', err);
}

function complete() {
    console.log('complete');
}