where method

Stream<EventFluxData> where(
  1. String eventType
)

Returns a filtered stream that only emits events matching eventType.

Implementation

Stream<EventFluxData> where(String eventType) {
  if (stream == null) return const Stream.empty();
  return stream!.where((event) => event.event == eventType);
}