Package io.micronaut.http.netty.stream

Class JsonSubscriber

java.lang.Object

io.micronaut.http.netty.stream.JsonSubscriber

@Internal
public final class JsonSubscriber
extends Object

A Reactor subscriber used to handle JSON content. It delegates to an upstream subscriber, wrapping them with opening/closing brackets where necessary.

Constructor Summary

Constructors

Constructor	Description
JsonSubscriber()

Method Summary

Modifier and Type	Method	Description
static reactor.core.publisher.Flux<io.netty.handler.codec.http.HttpContent>	lift(Publisher<io.netty.handler.codec.http.HttpContent> publisher)

Methods inherited from class java.lang.Object

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

Constructor Details

JsonSubscriber

public JsonSubscriber()

Method Details

lift

public static reactor.core.publisher.Flux<io.netty.handler.codec.http.HttpContent> lift(Publisher<io.netty.handler.codec.http.HttpContent> publisher)