anchor.diff:  
     TarabishSocket(url) {
       eventMap = new Map();
  -    webSocket = new ReconnectingSocket(url, _receiveEvent);
  +    webSocket = new ReconnectingSocket(url);
  +    webSocket.onMessage.listen((e) => _receiveEvent(e.data));
     }
   
     _receiveEvent(String encodedMessage) {
  
positive.code:     }
  
      webSocket.onOpen.listen((e) {
        connected = true;
        print('Connected');
        retrySeconds = 2;
      });
  
      webSocket.onClose.listen((e) => scheduleReconnect());
      webSocket.onError.listen((e) => scheduleReconnect());
      webSocket.onMessage.listen((e) => callback(e.data));
    }
  
    send(String data) {
      webSocket.send(data);
    }
  }
  
  class TarabishSocket {
  
negative.code: class ReconnectingSocket {
    WebSocket webSocket;
    String url;
  
    ReconnectingSocket(this.url) {
      _init();
    }
  
  