import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.AtomicReference;
import java.util.function.Consumer;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.AtomicReference;
import java.util.function.Consumer;
private final ListeningExecutorService threadPool;
private final ConnectionSupplier connectionSupplier;
private final ListeningExecutorService threadPool;
private final ConnectionSupplier connectionSupplier;
private final AtomicReference<String> redirectUri = new AtomicReference<>();
private final AtomicReference<File> file = new AtomicReference<>();
private final AtomicReference<InputStream> payload = new AtomicReference<>();
private final AtomicReference<String> redirectUri = new AtomicReference<>();
private final AtomicReference<File> file = new AtomicReference<>();
private final AtomicReference<InputStream> payload = new AtomicReference<>();
private final AtomicReference<String> targetFilename = new AtomicReference<>();
private final List<Consumer<String>> keyGenerateds = new CopyOnWriteArrayList<>();
private final AtomicReference<String> targetFilename = new AtomicReference<>();
private final List<Consumer<String>> keyGenerateds = new CopyOnWriteArrayList<>();
this.threadPool = MoreExecutors.listeningDecorator(threadPool);
this.connectionSupplier = connectionSupplier;
this.threadPool = MoreExecutors.listeningDecorator(threadPool);
this.connectionSupplier = connectionSupplier;
}
private Optional<Key> execute(String uri) throws InterruptedException, ExecutionException, IOException {
}
private Optional<Key> execute(String uri) throws InterruptedException, ExecutionException, IOException {
- String identifier = new RandomIdentifierGenerator().generate();
- ClientPut clientPut = createClientPutCommand(uri, identifier);
+ ClientPut clientPut = createClientPutCommand(uri, identifierGenerator.get());
try (ClientPutDialog clientPutDialog = new ClientPutDialog()) {
return clientPutDialog.send(clientPut).get();
}
try (ClientPutDialog clientPutDialog = new ClientPutDialog()) {
return clientPutDialog.send(clientPut).get();
}