websocket.ts

public start(url: string): void {
    console.log("connecting to " + url);
    let self = this;

    this.url = url;

    this.ws = Observable.webSocket(this.url);

    this.socket = this.ws.subscribe({

      next: (data: MessageEvent) => {
        if (data['type'] == 'welcome') {
          self.opened.next(true);
        }
        this.message.next(data);
      },
      error: () => {
        console.log('failed to connect');
        self.opened.next(false);
        this.message.next({ type: 'closed' });

        self.socket.unsubscribe();

        // setTimeout( () => {
        //     self.start( self.url );
        // }, 1000 );

      },
      complete: () => {
        console.log('Connection to server terminated');
        this.message.next({ type: 'closed' });
      }

    });

  }