public class BroadcasterFuture<E> extends Object implements Future
Future that can be used when awaiting for a Broadcaster to finish
its broadcast operation to AtmosphereHandler.| Constructor and Description |
|---|
BroadcasterFuture(E msg) |
BroadcasterFuture(E msg,
int latchCount) |
BroadcasterFuture(Future<?> innerFuture,
E msg) |
BroadcasterFuture(Future<?> innerFuture,
E msg,
int latchCount) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
cancel(boolean b) |
BroadcasterFuture<E> |
done()
Invoked when a
Broadcaster completed its broadcast operation. |
E |
get() |
E |
get(long l,
TimeUnit tu) |
boolean |
isCancelled() |
boolean |
isDone() |
public BroadcasterFuture(E msg)
public BroadcasterFuture(E msg, int latchCount)
public boolean isCancelled()
isCancelled in interface Futurepublic BroadcasterFuture<E> done()
Broadcaster completed its broadcast operation.public E get() throws InterruptedException, ExecutionException
get in interface FutureInterruptedExceptionExecutionExceptionpublic E get(long l, TimeUnit tu) throws InterruptedException, ExecutionException, TimeoutException
get in interface FutureInterruptedExceptionExecutionExceptionTimeoutExceptionCopyright © 2016. All rights reserved.