anchor.diff:  
     reconnect() {
       if(connection != null) {
  -      String ocid = connection.connectionId;
  +      String oCid = connection.connectionId;
         disconnect();
         connect();
  -      eventQueue.forEach((int i, WsEvent e) {
  -        if(e != null && e.connectionId == ocid && e is ! WsResult) triggerEvent(e);
  +      _eventQueue.forEach((int i, WsEvent e) {
  +        if(e != null && e.connectionId == oCid && e is ! WsResult) triggerEvent(e);
         });
       }
     }
  
positive.code: 
    WebSocketRails(this.url);
  
    Stream<WsEvent> get onOpen => onOpenController.stream;
  
    connect() {
      if(connection == null) {
  
negative.code:   String url;
    int state;
    WebSocketConnection connection;
    Map<String, Channel> _channels = {};
    Map<int, WsEvent> _eventQueue = {};
    Map<int, Completer> _eventQueueCompleter = {};
  
  
    static const int STATE_DISCONNECTED = 0;
    static const int STATE_CONNECTING = 1;
  