package org.reactivecouchbase.concurrent;

import com.google.common.base.Throwables;

import java.util.concurrent.TimeUnit;

public class Await {
    public static <T> T result(Future<T> future, Long timeout, TimeUnit unit) {
        try {
            return future.toJucFuture().get(timeout, unit);
        } catch (Exception e) {
            throw Throwables.propagate(e);
        }
    }
}

@@ -36,16 +36,61 @@
 rrent;%0A%0A
+import com.google.common.base.Preconditions;%0A
 import c
@@ -260,24 +260,68 @@
 nit unit) %7B%0A
+        Preconditions.checkNotNull(future);%0A
         try 

Add check