public abstract class BlockSource extends org.agilewiki.jactor.lpc.JLPCActor implements Finisher
Modifier and Type | Field and Description |
---|---|
protected BlockFlowBuffer |
blockFlowBuffer |
Constructor and Description |
---|
BlockSource() |
Modifier and Type | Method and Description |
---|---|
void |
finish(org.agilewiki.jactor.RP rp) |
void |
setNext(BlockProcessor nextInPipeline)
Creates a buffered connection to the block processor that is next in the pipeline.
|
acceptEvent, acceptRequest, getActorType, getAncestor, getExceptionHandler, getFactory, getMailbox, getMailboxFactory, getMatch, getParent, hasDataItem, haveEvents, initialize, initialize, initialize, initialize, initialize, requirements, responseFrom, send, send, sendEvent, setExceptionHandler, setInitialBufferCapacity
protected BlockFlowBuffer blockFlowBuffer
public void setNext(BlockProcessor nextInPipeline) throws Exception
nextInPipeline
- The next block processor in the pipeline.Exception
Copyright © 2013. All Rights Reserved.