Class OnSubscribeOnAssembly<T>

java.lang.Object
rx.internal.operators.OnSubscribeOnAssembly<T>
Type Parameters:
T - the value type
All Implemented Interfaces:
Action, Action1<Subscriber<? super T>>, Function, Observable.OnSubscribe<T>

public final class OnSubscribeOnAssembly<T> extends Object implements Observable.OnSubscribe<T>
Captures the current stack when it is instantiated, makes it available through a field and attaches it to all passing exception.
  • Field Details

    • source

      final Observable.OnSubscribe<T> source
    • stacktrace

      final String stacktrace
    • fullStackTrace

      public static volatile boolean fullStackTrace
      If set to true, the creation of PublisherOnAssembly will capture the raw stacktrace instead of the sanitized version.
  • Constructor Details

  • Method Details

    • createStacktrace

      static String createStacktrace()
    • call

      public void call(Subscriber<? super T> t)
      Specified by:
      call in interface Action1<T>