networkReceive method

  1. @override
void networkReceive(
  1. ISocket sender,
  2. NetworkBuffer buffer
)

Implementation

@override
void networkReceive(sender, NetworkBuffer buffer) {
  try {
    // Unassigned ?
    if (_sock == null) return;

    // Closed ?
    if (_sock?.state == SocketState.Closed ||
        _sock?.state == SocketState.Terminated) // || !connected)
      return;

    _lastAction = DateTime.now();

    if (!_processing) {
      _processing = true;

      try {
        while (buffer.available > 0 && !buffer.protected)
          dataReceived(buffer);
      } catch (ex) {}

      _processing = false;
    }
  } catch (ex) {
    print(ex);
    //Global.Log("NetworkConnection", LogType.Warning, ex.ToString());
  }
}