transportOpen method

  1. @override
Future<void> transportOpen({
  1. String? relayUrl,
})
override

Implementation

@override
Future<void> transportOpen({String? relayUrl}) async {
  relayUrl = relayUrl ?? relayUrl;
  transportExplicitlyClosed = false;
  await provider.connect();
  // wait for the subscriber to finish resubscribing to its topics
  final completer = Completer<void>();
  subscriber.once(SubscriberEvents.resubscribed, (_) {
    completer.complete();
  });
  return await completer.future;
}