Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

Misc

  • Loading branch information...
commit 65a0a5102dbb1158968adc4067f9ce72f4fd7ac8 1 parent c5753b2
@rkapsi authored
View
3  components/core/src/main/java/org/ardverk/dht/FutureManager.java
@@ -40,8 +40,7 @@
@Singleton
public class FutureManager implements Closeable {
- private final Set<AsyncFuture<?>> futures
- = new IdentityHashSet<AsyncFuture<?>>();
+ private final Set<AsyncFuture<?>> futures = new IdentityHashSet<>();
private boolean open = true;
View
2  components/core/src/main/java/org/ardverk/dht/concurrent/DHTFutureTask.java
@@ -63,7 +63,7 @@ protected boolean isEventThread() {
@Override
protected void fireOperationComplete(final AsyncFutureListener<V> first,
- final AsyncFutureListener<V>... others) {
+ @SuppressWarnings("unchecked") final AsyncFutureListener<V>... others) {
if (first == null) {
return;
View
2  components/core/src/main/java/org/ardverk/dht/concurrent/DHTValueFuture.java
@@ -76,7 +76,7 @@ protected boolean isEventThread() {
@Override
protected void fireOperationComplete(final AsyncFutureListener<V> first,
- final AsyncFutureListener<V>... others) {
+ @SuppressWarnings("unchecked") final AsyncFutureListener<V>... others) {
if (first == null) {
return;
View
2  components/core/src/main/java/org/ardverk/dht/concurrent/NopFuture.java
@@ -46,6 +46,6 @@ private NopFuture(Throwable t) {
*/
@Override
public void addAsyncFutureListener(AsyncFutureListener<T> l) {
- fireOperationComplete(l);
+ fireOperationComplete(l, (AsyncFutureListener<T>[])null);
}
}
Please sign in to comment.
Something went wrong with that request. Please try again.