anchor.diff:    async.Future<HetimaSendInfo> send(List<int> data) async {
       await _socket.add(data);
       return new HetimaSendInfo(0);
  +  }
  +  
  +  log(String message) {
  +    if(_verbose) {
  +      print("d..${message}");
  +    }
     }
   }
   
  
positive.code:       socket.listen((RawSocketEvent event) {
          if(event == RawSocketEvent.READ) {
            Datagram dg = socket.receive();
            print("read ${dg.address}:${dg.port} ${dg.data.length}");
            _receiveStream.add(new HetimaReceiveUdpInfo(dg.data, dg.address.address, dg.port));
          }
        });
  
negative.code:     try {
        _socket = await Socket.connect(peerAddress, peerPort);
        _socket.listen((List<int> data) {
          log('<<<lis>>> ');//${data.length} ${UTF8.decode(data)}');
          this.buffer.appendIntList(data,0, data.length);
          _receiveStream.add(new HetimaReceiveInfo(data));
        }, onDone: () {
          log('<<<Done>>>');
          _socket.close();
          _closeStream.add(new HetimaCloseInfo());
        }, onError: (e) {
          log('<<<Got error>>> $e');
          _socket.close();
          _closeStream.add(new HetimaCloseInfo());
        });
  