Skip navigation links
Reactor JavaDocs

Package reactor.core.processor

This package offers a suite of asynchronous Processor with backpressure support.

See: Description

Package reactor.core.processor Description

This package offers a suite of asynchronous Processor with backpressure support. Unlike Dispatcher, these components will be unique and bound to a given stream of data. A Processor will manage its own thread(s), one by Subscriber. The message-passing will be implementation dependant, e.g. using a RingBuffer. Usually, the boundary will be implemented with a queue-based event dispatching and the Reactive Stream contract will offer control over the available backlog. Long.MAX demand will however switch off the contract and rely on the impl coordination strategy to back-off, like the RingBuffer waiting strategy, to slow down the Processor publisher. These Processors are typically expansive to create, best to consider a few places to use them rather than creating them recurly.
Author:
Stephane Maldini
Skip navigation links
Reactor JavaDocs

Copyright © 2017. All rights reserved.