0
@@ -524,7 +524,21 @@ void ebb_client_release(ebb_client *client)
0
 {
0
   assert(client->in_use);
0
   client->in_use = FALSE;
0
+  
0
+  if(client->headers_written == FALSE) {
0
+    g_string_append(client->response_buffer, "\r\n");
0
+    client->headers_written = TRUE;
0
+  }
0
   client->body_written = TRUE;
0
+  
0
+  /* If the write_watcher isn't yet active, then start it. It could be that
0
+   * we're streaming and the watcher has been stopped. In that case we 
0
+   * start it again since we have more to write. */
0
+  if(ev_is_active(&client->write_watcher) == FALSE) {
0
+    set_nonblock(client->fd);
0
+    ev_io_start(client->server->loop, &client->write_watcher);
0
+  }
0
+  
0
   if(client->written == client->response_buffer->len)
0
     ebb_client_close(client);
0
 }