let obs = Rx.Observable

            .create(observer => observer.next(Date.now()))

            .publish();

obs.connect();

​

obs.subscribe(v => console.log("1st subscriber: " + v));

obs.subscribe(v => console.log("2nd subscriber: " + v));

obs.subscribe(v => console.log("3nd subscriber: " + v));

​

// obs.connect();