vapor · tanner0101 · Apr 5, 2018 · Apr 5, 2018 · Apr 5, 2018
diff --git a/Sources/Async/Deprecated.swift b/Sources/Async/Deprecated.swift
@@ -1,4 +1,3 @@
-
 extension Future {
     @available(*, deprecated, renamed: "cascade(promise:)")
     public func chain(to promise: Promise<T>) {

diff --git a/Sources/Async/QueueHandler.swift b/Sources/Async/QueueHandler.swift
@@ -65,15 +65,13 @@ public final class QueueHandler<In, Out>: ChannelInboundHandler {
     /// Triggers a context write if any output is enqueued.
     private func writeOutputIfEnqueued(ctx: ChannelHandlerContext) {
         VERBOSE("QueueHandler.sendOutput(ctx: \(ctx)) [outputQueue.count=\(outputQueue.count)]")
-        if let next = outputQueue.popLast() {
+        while let next = outputQueue.popLast() {
             for output in next {
                 ctx.write(wrapOutboundOut(output), promise: nil)
             }
             ctx.flush()
-            self.writeOutputIfEnqueued(ctx: ctx)
-        } else {
-            waitingCtx = ctx
         }
+        waitingCtx = ctx
     }
 
     /// MARK: ChannelInboundHandler conformance