AnalyticsStream<T extends Object?> extension

Extension on Stream<T> to automatically log analytics for streaming operations.

Provides analytics method to log each event or error using the global Analytics manager.

on

• Stream<T?>

Methods

analytics({String? name, String? msg}) → Stream<T?>

Available on Stream<T?>, provided by the AnalyticsStream extension

Wraps the stream with analytics logging.