subscribe<T extends E> abstract method

StreamSubscription<T> subscribe<T extends E>(
  1. void onData(
    1. T event
    ), {
  2. Stream<T> modify(
    1. Stream<T> stream
    )?,
  3. Function? onError,
  4. void onDone()?,
  5. bool? cancelOnError,
  6. StreamTransformer<T, T>? transform,
})

Subscribes to events of specific type T.

Provides flexible stream configuration through optional parameters:

  • modify - custom stream transformation
  • onError - error handling
  • onDone - completion handling
  • cancelOnError - subscription behavior on error
  • transform - stream transformation using StreamTransformer

Returns StreamSubscription that can be manually cancelled if needed.

Example:

final subscription = eventsSubscriptions.subscribe<UserLoggedIn>(
  (event) => print('User logged in: ${event.data}'),
  modify: (stream) => stream.distinct(),
  onError: (e) => print('Error: $e'),
);

Implementation

StreamSubscription<T> subscribe<T extends E>(
  void Function(T event) onData, {
  Stream<T> Function(Stream<T> stream)? modify,
  Function? onError,
  void Function()? onDone,
  bool? cancelOnError,
  StreamTransformer<T, T>? transform,
});