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 Future
public BroadcasterFuture<E> done()
Broadcaster
completed its broadcast operation.public E get() throws InterruptedException, ExecutionException
get
in interface Future
InterruptedException
ExecutionException
public E get(long l, TimeUnit tu) throws InterruptedException, ExecutionException, TimeoutException
get
in interface Future
InterruptedException
ExecutionException
TimeoutException
Copyright © 2016. All rights reserved.