0
@@ -580,6 +580,8 @@ static void on_client_writable(struct ev_loop *loop, ev_io *watcher, int revents
0
 
0
 void ebb_client_write_status(ebb_client *client, int status, const char *human_status)
0
 {
0
+  if(!client->open)
0
+    return;
0
   assert(client->status_written == FALSE);
0
   g_string_append_printf( client->response_buffer
0
                         , "HTTP/1.1 %d %s\r\n"
0
@@ -591,6 +593,8 @@ void ebb_client_write_status(ebb_client *client, int status, const char *human_s
0
 
0
 void ebb_client_write_header(ebb_client *client, const char *field, const char *value)
0
 {
0
+  if(!client->open)
0
+    return;
0
   assert(client->status_written == TRUE);
0
   assert(client->headers_written == FALSE);
0
   g_string_append_printf( client->response_buffer
0
@@ -602,6 +606,8 @@ void ebb_client_write_header(ebb_client *client, const char *field, const char *
0
 
0
 void ebb_client_write(ebb_client *client, const char *data, int length)
0
 {
0
+  if(!client->open)
0
+    return;
0
   g_string_append_len(client->response_buffer, data, length);
0
   if(client->began_transmission) {
0
     /* restart the watcher if we're streaming */
0
@@ -612,7 +618,8 @@ void ebb_client_write(ebb_client *client, const char *data, int length)
0
 
0
 void ebb_client_begin_transmission(ebb_client *client)
0
 {
0
-  assert(client->open);
0
+  if(!client->open)
0
+    return;
0
   assert(FALSE == ev_is_active(&client->write_watcher));
0
   
0
   /* assure the socket is still in non-blocking mode */
0
@@ -641,7 +648,9 @@ int ebb_client_read(ebb_client *client, char *buffer, int length)
0
 {
0
   size_t read;
0
   
0
-  assert(client->open);
0
+  if(!client->open) {
0
+    return -1;
0
+  }
0
   assert(client_finished_parsing);
0
   
0
   if(client->upload_file) {