subscribe method

Future<EventBusSubscribeStream> subscribe(
  1. SubscribeRequest req, {
  2. Map<String, String>? metadata,
  3. Duration? timeout,
})

Implementation

Future<EventBusSubscribeStream> subscribe(SubscribeRequest req,
    {Map<String, String>? metadata, Duration? timeout}) async {
  return EventBusSubscribeStream(
      await _channel.serverStream("/grpcdc.events.v1.EventBus/Subscribe", req,
          metadata: metadata, timeout: timeout));
}