diff --git a/src/main/java/net/schmizz/sshj/sftp/RemoteFile.java b/src/main/java/net/schmizz/sshj/sftp/RemoteFile.java
index 8b208faf..4d78084e 100644
--- a/src/main/java/net/schmizz/sshj/sftp/RemoteFile.java
+++ b/src/main/java/net/schmizz/sshj/sftp/RemoteFile.java
@@ -15,24 +15,15 @@
  */
 package net.schmizz.sshj.sftp;
 
-import net.schmizz.concurrent.Promise;
 import net.schmizz.sshj.sftp.Response.StatusCode;
 
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.OutputStream;
-import java.util.Queue;
-import java.util.concurrent.LinkedBlockingQueue;
 
 public class RemoteFile
         extends RemoteResource {
 
-    public static final int DEFAULT_CONCURRENT_REQUESTS = 10;
-
-    protected volatile int concurrentRequests = DEFAULT_CONCURRENT_REQUESTS;
-
-    private Queue<Promise<Response, SFTPException>> writeRequestsQueue = new LinkedBlockingQueue<Promise<Response, SFTPException>>();
-
     public RemoteFile(Requester requester, String path, String handle) {
         super(requester, path, handle);
     }
@@ -82,14 +73,11 @@ public class RemoteFile
 
     public void write(long fileOffset, byte[] data, int off, int len)
             throws IOException {
-        Request request = newRequest(PacketType.WRITE)
+        requester.doRequest(newRequest(PacketType.WRITE)
                                     .putUInt64(fileOffset)
                                     .putUInt32(len - off)
-                                    .putRawBytes(data, off, len);
-        writeRequestsQueue.add(requester.request(request));
-        while (writeRequestsQueue.size() >= getConcurrentRequests()) {
-            requester.retrieve(writeRequestsQueue.remove());
-        }
+                                    .putRawBytes(data, off, len)
+        ).ensureStatusPacketIsOK();
     }
 
     public void setAttributes(FileAttributes attrs)
@@ -198,23 +186,4 @@ public class RemoteFile
         }
 
     }
-
-    @Override
-    public void close() throws IOException {
-        try {
-            while(!writeRequestsQueue.isEmpty()) {
-                requester.retrieve(writeRequestsQueue.remove());
-            }
-        } finally {
-            super.close();
-        }
-    }
-
-    public void setConcurrentRequests(int concurrentRequests) {
-        this.concurrentRequests = concurrentRequests;
-    }
-
-    public int getConcurrentRequests() {
-        return concurrentRequests;
-    }
 }
diff --git a/src/main/java/net/schmizz/sshj/sftp/Requester.java b/src/main/java/net/schmizz/sshj/sftp/Requester.java
index 077f303f..2cb4cba7 100644
--- a/src/main/java/net/schmizz/sshj/sftp/Requester.java
+++ b/src/main/java/net/schmizz/sshj/sftp/Requester.java
@@ -15,8 +15,6 @@
  */
 package net.schmizz.sshj.sftp;
 
-import net.schmizz.concurrent.Promise;
-
 import java.io.IOException;
 
 public interface Requester {
@@ -28,10 +26,4 @@ public interface Requester {
     Response doRequest(Request req)
             throws IOException;
 
-    Promise<Response, SFTPException> request(Request request)
-            throws IOException;
-
-    void retrieve(Promise<Response, SFTPException> response)
-            throws IOException;
-
 }
diff --git a/src/main/java/net/schmizz/sshj/sftp/SFTPEngine.java b/src/main/java/net/schmizz/sshj/sftp/SFTPEngine.java
index 2b3424f2..2814f973 100644
--- a/src/main/java/net/schmizz/sshj/sftp/SFTPEngine.java
+++ b/src/main/java/net/schmizz/sshj/sftp/SFTPEngine.java
@@ -15,7 +15,6 @@
  */
 package net.schmizz.sshj.sftp;
 
-import net.schmizz.concurrent.Promise;
 import net.schmizz.sshj.common.SSHException;
 import net.schmizz.sshj.connection.channel.direct.Session.Subsystem;
 import net.schmizz.sshj.connection.channel.direct.SessionFactory;
@@ -269,17 +268,4 @@ public class SFTPEngine
         out.flush();
     }
 
-    @Override
-    public Promise<Response, SFTPException> request(Request req) throws IOException {
-        reader.expectResponseTo(req);
-        log.debug("Sending {}", req);
-        transmit(req);
-        return req.getResponsePromise();
-    }
-
-    @Override
-    public void retrieve(Promise<Response, SFTPException> request)
-            throws IOException {
-        request.retrieve(timeout, TimeUnit.SECONDS).ensureStatusPacketIsOK();
-    }
 }