revert last commit

pgmoon/redbean.moon

@@ -38,34 +38,26 @@ class RedbeanSocket
     sent, err
 
   receive: (...) =>
-    pattern = flatten ...
-    buf = ""
+    @buf = "" unless @buf
+
     CANREAD = unix.POLLIN | unix.POLLRDNORM | unix.POLLRDBAND
-    size = tonumber pattern
+    size = ...
     if size
-        events = assert unix.poll @unix_socket: unix.POLLIN
-        return nil, "timeout" unless events[@unix_socket]
-        return nil, "close" if events[@unix_socket] & CANREAD == 0
-        if size > 81920
-          size = 81920
-        rec = unix.recv @unix_socket, size
-        if rec
-            buf = rec
-        else
-            collectgarbage!
-            buf = assert unix.recv @unix_socket, size
-        return buf
-
-    while not buf\find "\n"
-        rec = unix.recv @unix_socket, 4096
-        if rec
-            buf ..= rec
-        else
-            collectgarbage!
-            buf ..= assert unix.recv @unix_socket, 4096
+        if #@buf < size
+            events = assert unix.poll @unix_socket: unix.POLLIN
+            return nil, "timeout" unless events[@unix_socket]
+            return nil, "close" if events[@unix_socket] & CANREAD == 0
+            @buf = @buf .. assert unix.recv @unix_socket, size-#@buf
+        res = @buf\sub 1, size
+        @buf = @buf\sub size+1
+        return res
+
+    while not @buf\find "\n"
+        @buf = @buf .. assert unix.recv @unix_socket, 4096
 
-    pos = buf\find "\n"
-    res = buf\sub(1, pos-1)\gsub "\r", ""
+    pos = @buf\find "\n"
+    res = @buf\sub(1, pos-1)\gsub "\r", ""
+    @buf = @buf\sub pos+1
     res
 
   close: =>