public class LocalProcessChannel<T extends Serializable> extends Object implements ProcessChannel<T>
Constructor and Description |
---|
LocalProcessChannel(NoticeableFuture<T> noticeableFuture,
ObjectOutputStream objectOutputStream,
AsyncBroker<Long,Serializable> asyncBroker) |
Modifier and Type | Method and Description |
---|---|
NoticeableFuture<T> |
getProcessNoticeableFuture() |
<V extends Serializable> |
write(ProcessCallable<V> processCallable) |
public LocalProcessChannel(NoticeableFuture<T> noticeableFuture, ObjectOutputStream objectOutputStream, AsyncBroker<Long,Serializable> asyncBroker)
public NoticeableFuture<T> getProcessNoticeableFuture()
getProcessNoticeableFuture
in interface ProcessChannel<T extends Serializable>
public <V extends Serializable> NoticeableFuture<V> write(ProcessCallable<V> processCallable)
write
in interface ProcessChannel<T extends Serializable>