Class SerializedObserver<T>

    • Constructor Detail

      • SerializedObserver

        public SerializedObserver​(@NonNull
                                  @NonNull Observer<? super T> downstream)
        Construct a SerializedObserver by wrapping the given actual Observer.
        Parameters:
        downstream - the actual Observer, not null (not verified)
      • SerializedObserver

        public SerializedObserver​(@NonNull
                                  @NonNull Observer<? super T> actual,
                                  boolean delayError)
        Construct a SerializedObserver by wrapping the given actual Observer and optionally delaying the errors till all regular values have been emitted from the internal buffer.
        Parameters:
        actual - the actual Observer, not null (not verified)
        delayError - if true, errors are emitted after regular values have been emitted