                     doDisconnect(errorWithDetail("second and beyond of fragment message must be a continue frame",
                         code: errCode))
                     writeError(errCode)
-                    return
+                    return emptyBuffer
                 }
                 response!.buffer!.appendData(data)
             }

    }
    
}

        if !connected {
            processTCPHandshake(buffer, bufferLen: length)
        } else {
            processRawMessagesInBuffer(buffer, bufferLen: length)
        }
        inputQueue = inputQueue.filter{$0 != data}
        dequeueInput()
