connect method

  1. @override
Future<Map<String, Object?>> connect(
  1. int protocolVersion,
  2. Map<String, Object?> request
)
override

Sends a connect request, returning the decoded ConnectEvent.

Implementation

@override
Future<Map<String, Object?>> connect(
  int protocolVersion,
  Map<String, Object?> request,
) async {
  connectRequests.add(request);
  final failure = _takeFailure();
  if (failure != null) throw failure;
  return connectResponse ?? (throw StateError('No connectResponse set.'));
}