Package io.micronaut.http.netty.reactive

package io.micronaut.http.netty.reactive
NOTICE: Classes in this package are forked from https://github.com/playframework/netty-reactive-streams.
Since:
1.0
Author:
graemerocher
  • Class
    Description
    CancelledSubscriber<T>
    A cancelled subscriber.
    HandlerPublisher<T>
    Publisher for a Netty Handler.
    HandlerSubscriber<T>
    Subscriber that publishes received messages to the handler pipeline.
    HotObservable<T>
    A contract for a publisher that buffers data to allow for the release of that data if there will not be a subscriber.