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>