All Classes and Interfaces

Class
Description
Client side execution pipeline assembler that creates AsyncClientExchangeHandler instances with the defined message exchange pipeline optimized for JSON message exchanges that triggers the given FutureCallback or CompletableFuture upon completion.
Exchange completion stage.
Exchange result signal stage.
Server side execution pipeline assembler that supplies AsyncServerExchangeHandler instances with the defined message exchange pipeline optimized for JSON message exchanges.
Event-driven, reactive JSON tokenizer that consumes data from a sequence ByteBuffer objects and emits events to JsonTokenConsumer.
Event-driven bulk JSON reader that can read arrays of objects while buffering only a single array element in memory.
Represents an event recipient that can react to JSON input.
JsonTokenEventHandler implementation that assembles an JsonNode instance based on JSON token events it receives and passes the resultant object to a Consumer.
AsyncEntityConsumer implementation that de-serializes incoming HTTP message entity into an JsonNode instance.
AsyncEntityConsumer implementation that de-serializes incoming HTTP message entity into an JsonNode instance if the message content type is ContentType.APPLICATION_JSON or as a single text JsonNode if the message content type is not supported.
AsyncEntityProducer implementation that generates a message body containing serialized content of the given JsonNode object.
AsyncEntityConsumer implementation that converts incoming HTTP message entity into a sequence of JsonNode instance and passes those objects to the JsonResultSink.
AsyncEntityConsumer implementation that de-serializes incoming HTTP message entity into an instance of the given class.
AsyncEntityProducer implementation that generates a message body containing serialized content of the given JSON object.
Factory class for JSON AsyncRequestConsumers.
Factory class for JSON AsyncRequestProducers.
Factory class for JSON AsyncResponseConsumers.
Factory class for JSON AsyncResponseProducers.
Represents a recipient of zero or many results of JSON message processing.
AsyncEntityConsumer implementation that converts incoming HTTP message entity into a sequence of instances of the given class and passes those objects to the JsonResultSink.
AsyncEntityProducer implementation that generates a message body containing serialized content of a sequence of JSON objects.
Represents an event recipient that can react to a stream of consecutive JSON tokens.
AsyncEntityConsumer implementation that converts incoming HTTP message entity into a sequence of JSON tokens passed as events to the given JsonTokenEventHandler.
 
Represents a handler of JSON token events.
JsonTokenConsumer implementation that converts JSON tokens into event signals for JsonTokenEventHandler.
Classic (blocking) JSON tokenizer that consumes data from InputStream and emits events to JsonTokenConsumer.
Abstract object stream channel.
Abstract asynchronous object producer.
JsonTokenConsumer implementation that copies Json token events into TokenBuffer and passes those buffers to the JsonResultSink.
JsonTokenConsumer decorator that filters out top level opening and closing array tokens.