RegisteredSubscription<N extends Object> constructor

RegisteredSubscription<N extends Object>({
  1. required String id,
  2. required StreamController<N> controller,
  3. required Future<void> unsubscribe(),
  4. void onReconnect()?,
})

Implementation

RegisteredSubscription({
  required this.id,
  required this.controller,
  required Future<void> Function() unsubscribe,
  this.onReconnect,
}) : pipeSubscription = PipeSubscription<N>(
        stream: controller.stream,
        unsubscribe: unsubscribe,
      );