GamesService.ConnectableObservable.ts

GamesService.ConnectableObservable.ts

@Injectable()
export class GamesService {

    /** Internal model state */
    private games:Object[];

    /** Private Subject **/
    private _gamesSource:Subject<Object[]> = new Subject<Object[]>();

    /** Public Observer  **/
    gamesChanged$:Observable<Object[]> =
        /** Create an Observable */
        this._gamesSource.asObservable()
            /**
             * publishReplay() = Changes return type fo ConnectableObservable see: http://reactivex.io/documentation/operators/replay.html
             * The Observable will always emit the same complete sequence to any future observers,
             * even those observers that subscribe after the connectable Observable has begun to emit items to other subscribed observers.
             */
            .publishReplay() // returns ConnectableObservable<T>
            /**
             * refCount() = turns ConnectableObservable and returns an ordinary Observable see: http://reactivex.io/documentation/operators/refcount.html
             * Joining & disconnecting the underlying the ConnectableObservable to the Connectable.
             * RefCount then keeps track of how many other observers subscribe to it and does not disconnect from the underlying connectable Observable until the last observer has done so.
             */
            .refCount() // return Observable<T>
            /** share() = This will allow multiple Subscribers to one Observable */
            .share();  // return Observable<T>

}