io.micronaut.http.server.netty

Interface HttpContentProcessor<T>

Type Parameters:

T - The type

All Superinterfaces:

Publisher<T>, Subscriber<io.netty.buffer.ByteBufHolder>, Toggleable

All Known Implementing Classes:

AbstractBufferingHttpContentProcessor, AbstractHttpContentProcessor, DefaultHttpContentProcessor, FormDataHttpContentProcessor, JsonContentProcessor

public interface HttpContentProcessor<T>
extends Publisher<T>, Subscriber<io.netty.buffer.ByteBufHolder>, Toggleable

A reactive streams Processor that processes incoming ByteBufHolder and outputs a given type.

Since:

1.0

Author:

Graeme Rocher

Method Summary

Methods inherited from interface org.reactivestreams.Publisher

subscribe

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext, onSubscribe

Methods inherited from interface io.micronaut.core.util.Toggleable

isEnabled