close method

@override Future<void> close({ dynamic error, })

Implementation

@override
Future<void> close({error}) async {
  _openAttempt++;
  _outboundBuffer?.clear();
  final socket = _socket;
  _socket = null;
  complete(_onDisconnect, error);
  if (socket == null) return;
  try {
    if (error == null) await socket.close();
  } finally {
    // Do not wait for inbound EOF: the caller may never consume receive().
    socket.destroy();
  }
}