createSubscriber method

  1. @protected
TestSubscriber<T> createSubscriber(
  1. Observer<T> observer
)
inherited

Implementation

@protected
TestSubscriber<T> createSubscriber(Observer<T> observer) {
  final subscriber = TestSubscriber<T>(scheduler, observer);
  scheduler.subscribers.add(subscriber);
  return subscriber;
}