org.threadly.concurrent.processing

Classes

• BlockingQueueConsumer
• FlowControlledNoFailureProcessor
• FlowControlledNoResultProcessor
• FlowControlledProcessor