public final class HalfSerializer extends Object
Modifier and Type | Method and Description |
---|---|
static void |
onComplete(Observer<?> observer,
AtomicInteger wip,
AtomicThrowable error)
Emits an onComplete signal or an onError signal with the given error or indicates
the concurrently running onNext should do that.
|
static void |
onComplete(org.reactivestreams.Subscriber<?> subscriber,
AtomicInteger wip,
AtomicThrowable error)
Emits an onComplete signal or an onError signal with the given error or indicates
the concurrently running onNext should do that.
|
static void |
onError(Observer<?> observer,
Throwable ex,
AtomicInteger wip,
AtomicThrowable error)
Emits the given exception if possible or adds it to the given error container to
be emitted by a concurrent onNext if one is running.
|
static void |
onError(org.reactivestreams.Subscriber<?> subscriber,
Throwable ex,
AtomicInteger wip,
AtomicThrowable error)
Emits the given exception if possible or adds it to the given error container to
be emitted by a concurrent onNext if one is running.
|
static <T> void |
onNext(Observer<? super T> observer,
T value,
AtomicInteger wip,
AtomicThrowable error)
Emits the given value if possible and terminates if there was an onComplete or onError
while emitting, drops the value otherwise.
|
static <T> void |
onNext(org.reactivestreams.Subscriber<? super T> subscriber,
T value,
AtomicInteger wip,
AtomicThrowable error)
Emits the given value if possible and terminates if there was an onComplete or onError
while emitting, drops the value otherwise.
|
public static <T> void onNext(org.reactivestreams.Subscriber<? super T> subscriber, T value, AtomicInteger wip, AtomicThrowable error)
T
- the value typesubscriber
- the target Subscriber to emit tovalue
- the value to emitwip
- the serialization work-in-progress counter/indicatorerror
- the holder of Throwablespublic static void onError(org.reactivestreams.Subscriber<?> subscriber, Throwable ex, AtomicInteger wip, AtomicThrowable error)
subscriber
- the target Subscriber to emit toex
- the Throwable to emitwip
- the serialization work-in-progress counter/indicatorerror
- the holder of Throwablespublic static void onComplete(org.reactivestreams.Subscriber<?> subscriber, AtomicInteger wip, AtomicThrowable error)
subscriber
- the target Subscriber to emit towip
- the serialization work-in-progress counter/indicatorerror
- the holder of Throwablespublic static <T> void onNext(Observer<? super T> observer, T value, AtomicInteger wip, AtomicThrowable error)
T
- the value typeobserver
- the target Observer to emit tovalue
- the value to emitwip
- the serialization work-in-progress counter/indicatorerror
- the holder of Throwablespublic static void onError(Observer<?> observer, Throwable ex, AtomicInteger wip, AtomicThrowable error)
observer
- the target Subscriber to emit toex
- the Throwable to emitwip
- the serialization work-in-progress counter/indicatorerror
- the holder of Throwablespublic static void onComplete(Observer<?> observer, AtomicInteger wip, AtomicThrowable error)
observer
- the target Subscriber to emit towip
- the serialization work-in-progress counter/indicatorerror
- the holder of ThrowablesCopyright © 2019. All rights reserved.