Use byte queue in http_transport_handle_read

1 files changed, 5 insertions, 7 deletions

diff --git a/src/lachttp.c b/src/lachttp.c
index 77b28a5..c4cf316 100644
--- a/src/lachttp.c
+++ b/src/lachttp.c
@@ -2242,9 +2242,6 @@ static void
 http_transport_handle_read (HttpTransport                *transport,
                             const LacConnectionReadEvent *read_event)
 {
-    const gchar *data = (const gchar *)read_event->data;
-    guint len = read_event->len;
-
 #if 0
     {
         int i;
@@ -2262,9 +2259,11 @@ http_transport_handle_read (HttpTransport                *transport,
     }    
 #endif
 
-    while (len > 0)
+    while (lac_byte_queue_get_length (read_event->byte_queue) > 0)
     {
         gssize used;
+        gsize len;
+        const gchar *data = lac_byte_queue_peek (read_event->byte_queue, &len);
         
         if (!transport->current)
         {
@@ -2404,9 +2403,8 @@ http_transport_handle_read (HttpTransport                *transport,
                 lac_connection_close (transport->connection);
             }
         }
-        
-        len -= used;
-        data += used;
+
+        lac_byte_queue_delete_head (read_event->byte_queue, used);
     }
 }