future.setFuture((Future) scheduler.schedule(callable, waitNanos, TimeUnit.NANOSECONDS));
return true;
} catch (Throwable t) {
failure = t;
if (listeners != null)
<BUG>listeners.complete(null, t, this, false);
</BUG>
future.complete(null, failure);
}
}

future.setFuture((Future) scheduler.schedule(callable, waitNanos, TimeUnit.NANOSECONDS));
return true;
} catch (Throwable t) {
failure = t;
if (listeners != null)
listeners.handleComplete(null, t, this, false);
future.complete(null, failure);
}
}
