setup<T> method

T setup<T>(T builder())

Set up this observer with the given builder

Implementation

T setup<T>(T Function() builder) {
  // Clear out existing streams (for hot reloading)
  _clearStreams();

  // Calling the builder will add any relevant streams to the observer
  final built = runRxZoned(builder, registrar: _addStream);
  if (!_listenable) {
    throw RxObserverIsNotListenable();
  }
  return built;
}