send method

  1. @override
void send(
  1. List<Map> packets
)
override

Implementation

@override
void send(List<Map> packets) {
  var send = (data, Map packet) {
    _logger.fine('writing "$data"');

    // always creates a new object since ws modifies it
//      var opts = {};
//      if (packet.options != null) {
//        opts['compress'] = packet.options['compress'];
//      }
//
//      if (this.perMessageDeflate != null) {
//        var len = data is String ? UTF8.encode(data).length : data.length;
//        if (len < this.perMessageDeflate['threshold']) {
//          opts['compress'] = false;
//        }
//      }

//      this.writable = false;
    connect!.websocket?.add(data);
  };

//    function onEnd (err) {
//      if (err) return self.onError('write error', err.stack);
//      self.writable = true;
//      self.emit('drain');
//    }
  for (var i = 0; i < packets.length; i++) {
    var packet = packets[i];
    PacketParser.encodePacket(packet,
        supportsBinary: supportsBinary, callback: (_) => send(_, packet));
  }
}