$runHandler method

void $runHandler(dynamic message)

Run all registered handlers for the subscription. This is an internal method exposed for testing.

Implementation

void $runHandler(dynamic message) {
  // Emit to stream first
  if (!_messageStreamController.isClosed) {
    _messageStreamController.add(message);
  }

  // Then run callbacks (iterate over a snapshot to allow handlers to remove themselves safely)
  for (final handler in List<void Function(dynamic)>.from(_handlers)) {
    handler(message);
  }
}