publish method

Future<PublishReply> publish(
  1. PublishRequest req, {
  2. Map<String, String>? metadata,
  3. Duration? timeout,
})

Implementation

Future<PublishReply> publish(PublishRequest req,
    {Map<String, String>? metadata, Duration? timeout}) async {
  final resp = PublishReply();
  await _channel.unary("/grpcdc.events.v1.EventBus/Publish", req, resp, metadata: metadata, timeout: timeout);
  return resp;
}