readPacket method

Implementation

@override
Future<SshBinaryPacket> readPacket() async {
  _ensureConnected();
  _throwTerminalErrorIfNeeded();

  if (_packetQueue.isNotEmpty) {
    return _packetQueue.removeFirst();
  }

  final Completer<SshBinaryPacket> completer = Completer<SshBinaryPacket>();
  _pendingPacketReaders.add(completer);
  return completer.future;
}