Formatting.

Author: dkocher

core/src/main/java/ch/cyberduck/core/worker/AbstractTransferWorker.java

@@ -147,7 +147,7 @@ protected enum Connection {
     /**
      * Release session from pool for transfer
      */
-    protected abstract void release(Session session, Connection type, BackgroundException failure);
+    protected abstract void release(Session<?> session, Connection type, BackgroundException failure);
 
     @Override
     public Boolean initialize() {
@@ -200,7 +200,7 @@ public void message(final String message) {
             for(TransferItem next : transfer.getRoots()) {
                 // Check if parent directory is found in set to determine status
                 this.prepare(next.remote, next.local, new TransferStatus()
-                        .setExists(!transfer.getRoots().stream().anyMatch(f -> next.remote.isChild(f.remote))), action);
+                        .setExists(transfer.getRoots().stream().noneMatch(f -> next.remote.isChild(f.remote))), action);
             }
             this.await();
             meter.reset();

core/src/main/java/ch/cyberduck/core/worker/ConcurrentTransferWorker.java

@@ -129,7 +129,7 @@ public boolean isRunning() {
     }
 
     @Override
-    protected void release(final Session session, final Connection type, final BackgroundException failure) {
+    protected void release(final Session<?> session, final Connection type, final BackgroundException failure) {
         switch(type) {
             case source:
                 source.release(session, failure);
@@ -176,7 +176,7 @@ public void await() throws BackgroundException {
 
     @Override
     protected void shutdown() {
-        // Always shutdown gracefully allowing the threads to return after checking transfer status
+        // Always shutdown gracefully, allowing the threads to return after checking transfer status
         pool.shutdown(true);
     }
 

core/src/main/java/ch/cyberduck/core/worker/SingleTransferWorker.java

@@ -37,10 +37,10 @@
 
 public class SingleTransferWorker extends AbstractTransferWorker {
 
-    private final Session source;
-    private final Session destination;
+    private final Session<?> source;
+    private final Session<?> destination;
 
-    public SingleTransferWorker(final Session source, final Session destination, final Transfer transfer, final TransferOptions options,
+    public SingleTransferWorker(final Session<?> source, final Session<?> destination, final Transfer transfer, final TransferOptions options,
                                 final TransferSpeedometer meter, final TransferPrompt prompt,
                                 final TransferErrorCallback error,
                                 final ProgressListener listener, final StreamListener streamListener,
@@ -51,7 +51,7 @@ public SingleTransferWorker(final Session source, final Session destination, fin
     }
 
     @Override
-    public Session borrow(final Connection type) {
+    public Session<?> borrow(final Connection type) {
         switch(type) {
             case source:
                 return source;
@@ -62,7 +62,7 @@ public Session borrow(final Connection type) {
     }
 
     @Override
-    protected void release(final Session session, final Connection type, final BackgroundException failure) {
+    protected void release(final Session<?> session, final Connection type, final BackgroundException failure) {
         //
     }