Package | Description |
---|---|
io.reactivex.internal.util |
Modifier and Type | Method and Description |
---|---|
static void |
HalfSerializer.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 |
HalfSerializer.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 |
HalfSerializer.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 |
HalfSerializer.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 |
HalfSerializer.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 |
HalfSerializer.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.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.