eventStream method

Stream<Event> eventStream({
  1. String? routingKeyFilter,
  2. String? krefFilter,
})
inherited

Subscribes to real-time events.

routingKeyFilter filters by routing key pattern (supports wildcards). krefFilter filters by kref pattern (supports wildcards).

Returns a stream of Event objects. The stream stays open until cancelled or the connection is lost.

Implementation

Stream<Event> eventStream({
  String? routingKeyFilter,
  String? krefFilter,
}) {
  final request = EventStreamRequest();
  if (routingKeyFilter != null && routingKeyFilter.isNotEmpty) {
    request.routingKeyFilter = routingKeyFilter;
  }
  if (krefFilter != null && krefFilter.isNotEmpty) {
    request.krefFilter = krefFilter;
  }
  return stub.eventStream(request, options: callOptions);
}