X-Git-Url: https://git.distorted.org.uk/~mdw/hippotat/blobdiff_plain/1321ad5f1dc05a97d58c4750863e645016fe0aa8..7b07f0b5fd215702dc58c53bd1cd7c63767f5710:/server

diff --git a/server b/server
index 2daf0b0..e3e28ce 100755
--- a/server
+++ b/server
@@ -102,20 +102,9 @@ class Client():
         break
 
       # request, and also some non-expired packets
-      while True:
-        packet = self.pq.popleft()
-        if packet is None: break
-
-        encoded = slip.encode(packet)
-        
-        if request.sentLength > 0:
-          if (request.sentLength + len(slip.delimiter)
-              + len(encoded) > self.max_batch_down):
-            break
-          request.write(slip.delimiter)
-
-        request.write(encoded)
-        self._pq.popLeft()
+      self._pq.process((lambda: request.sentLength),
+                       request.write,
+                       self.max_batch_down)
 
       assert(request.sentLength)
       self._rq.popLeft()