import {WeatherService} from './workers/WeatherService';
import {IWeatherUpdate} from '../common/interfaces/WeatherInterfaces';
import {IAccident} from '../common/interfaces/TrafficInterfaces';
import {TrafficService} from './workers/TrafficService';

import * as Rx from '@reactivex/rxjs';

export class RtBroker {

	weatherService: WeatherService;
	trafficService: TrafficService;

	weatherPub: Rx.Subject<IWeatherUpdate>;
	accidentPub: Rx.Subject<IAccident>;
    online:number = 0;

	constructor(public io:SocketIO.Server) {

		this.weatherService = new WeatherService();
		this.trafficService = new TrafficService();

		this.io.on('connection', (socket:SocketIO.Socket) => {
			console.log(`Connect from ${socket.client.id}!`);
            this.online += 1;
            console.log(`${this.online} clients online.`);
		});

        this.io.on('disconnect',  (who) => {
            console.log(`Disconnect from ${who}.`);
            this.online -= 1;
            console.log(`${this.online} clients online.`);
        });


		this.weatherPub = this.weatherService.getWeatherUpdatePub();
		this.weatherPub.subscribe(weatherUpdate => this.io.emit('weatherUpdate', weatherUpdate));

		this.accidentPub = this.trafficService.getAccidentPub();
		this.accidentPub.subscribe(accident => this.io.emit('accident', accident));
	}
}

import {WeatherService} from './workers/WeatherService';
import {IWeatherUpdate} from '../common/interfaces/WeatherInterfaces';
import {IAccident} from '../common/interfaces/TrafficInterfaces';
import {TrafficService} from './workers/TrafficService';

import * as Rx from '@reactivex/rxjs';

export class RtBroker {

	weatherService: WeatherService;
	trafficService: TrafficService;

	weatherPub: Rx.Subject<IWeatherUpdate>;
	accidentPub: Rx.Subject<IAccident>;

	constructor(public io:SocketIO.Server) {

		this.weatherService = new WeatherService();
		this.trafficService = new TrafficService();

		this.io.on('connection', function(socket:SocketIO.Socket){
			console.log(`Connect from ${socket.client.id}!`);
			//console.log('Got a connection.');
		});

		this.weatherPub = this.weatherService.getWeatherUpdatePub();
		this.weatherPub.subscribe(weatherUpdate => this.io.emit('weatherUpdate', weatherUpdate));

		this.accidentPub = this.trafficService.getAccidentPub();
		this.accidentPub.subscribe(accident => this.io.emit('accident', accident));
	}
}

--- 
+++ 
@@ -12,16 +12,25 @@
 
 	weatherPub: Rx.Subject<IWeatherUpdate>;
 	accidentPub: Rx.Subject<IAccident>;
+    online:number = 0;
 
 	constructor(public io:SocketIO.Server) {
 
 		this.weatherService = new WeatherService();
 		this.trafficService = new TrafficService();
 
-		this.io.on('connection', function(socket:SocketIO.Socket){
+		this.io.on('connection', (socket:SocketIO.Socket) => {
 			console.log(`Connect from ${socket.client.id}!`);
-			//console.log('Got a connection.');
+            this.online += 1;
+            console.log(`${this.online} clients online.`);
 		});
+
+        this.io.on('disconnect',  (who) => {
+            console.log(`Disconnect from ${who}.`);
+            this.online -= 1;
+            console.log(`${this.online} clients online.`);
+        });
+
 
 		this.weatherPub = this.weatherService.getWeatherUpdatePub();
 		this.weatherPub.subscribe(weatherUpdate => this.io.emit('weatherUpdate', weatherUpdate));
Put the traffic update time back to once a second
