@Internal public final class JsonSubscriber extends Object implements reactor.core.CoreSubscriber<io.netty.handler.codec.http.HttpContent>
Constructor and Description |
---|
JsonSubscriber(reactor.core.CoreSubscriber<? super io.netty.handler.codec.http.HttpContent> upstream) |
Modifier and Type | Method and Description |
---|---|
reactor.util.context.Context |
currentContext() |
static reactor.core.publisher.Flux<io.netty.handler.codec.http.HttpContent> |
lift(Publisher<io.netty.handler.codec.http.HttpContent> publisher) |
void |
onComplete()
On complete the opening bracket should be emitted
if no items were ever produced, then the closing bracket.
|
void |
onError(Throwable t) |
void |
onNext(io.netty.handler.codec.http.HttpContent o)
The goal is to prevent the emission of the
opening bracket if the underlying stream never emits
an item and only produces an error.
|
void |
onSubscribe(Subscription s) |
public JsonSubscriber(reactor.core.CoreSubscriber<? super io.netty.handler.codec.http.HttpContent> upstream)
public reactor.util.context.Context currentContext()
currentContext
in interface reactor.core.CoreSubscriber<io.netty.handler.codec.http.HttpContent>
public void onSubscribe(Subscription s)
onSubscribe
in interface Subscriber<io.netty.handler.codec.http.HttpContent>
onSubscribe
in interface reactor.core.CoreSubscriber<io.netty.handler.codec.http.HttpContent>
public void onNext(io.netty.handler.codec.http.HttpContent o)
onNext
in interface Subscriber<io.netty.handler.codec.http.HttpContent>
o
- The contentpublic void onError(Throwable t)
onError
in interface Subscriber<io.netty.handler.codec.http.HttpContent>
public void onComplete()
onComplete
in interface Subscriber<io.netty.handler.codec.http.HttpContent>
public static reactor.core.publisher.Flux<io.netty.handler.codec.http.HttpContent> lift(Publisher<io.netty.handler.codec.http.HttpContent> publisher)