io.micronaut.http.netty.stream

Class JsonSubscriber

java.lang.Object

io.micronaut.http.netty.stream.JsonSubscriber

All Implemented Interfaces:

org.reactivestreams.Subscriber<io.netty.handler.codec.http.HttpContent>

@Internal
public final class JsonSubscriber
extends java.lang.Object
implements org.reactivestreams.Subscriber<io.netty.handler.codec.http.HttpContent>

Constructor Summary

Constructors

Constructor and Description
JsonSubscriber(org.reactivestreams.Subscriber<? super io.netty.handler.codec.http.HttpContent> upstream)

Method Summary

Modifier and Type	Method and Description
void	onComplete() On complete the opening bracket should be emitted if no items were ever produced, then the closing bracket.
void	onError(java.lang.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(org.reactivestreams.Subscription s)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JsonSubscriber

public JsonSubscriber(org.reactivestreams.Subscriber<? super io.netty.handler.codec.http.HttpContent> upstream)

Method Detail

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<io.netty.handler.codec.http.HttpContent>

onNext

public 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.

Specified by:

onNext in interface org.reactivestreams.Subscriber<io.netty.handler.codec.http.HttpContent>

Parameters:

o - The content

onError

public void onError(java.lang.Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<io.netty.handler.codec.http.HttpContent>

onComplete

public void onComplete()

On complete the opening bracket should be emitted if no items were ever produced, then the closing bracket.

Specified by:

onComplete in interface org.reactivestreams.Subscriber<io.netty.handler.codec.http.HttpContent>