package com.google.api.gax.grpc;
import com.google.api.gax.bundling.ThresholdBundleHandle;
<BUG>import com.google.common.util.concurrent.ListenableFuture;</BUG>
import com.google.common.util.concurrent.SettableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
<BUG>class BundlingFuture<ResponseT> implements ListenableFuture<ResponseT> {
</BUG>
private final Lock lock = new ReentrantLock();

package com.google.api.gax.grpc;
import com.google.api.gax.bundling.ThresholdBundleHandle;
import com.google.common.util.concurrent.SettableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
class BundlingFuture<ResponseT> extends AbstractRpcFuture<ResponseT> {
private final Lock lock = new ReentrantLock();
