disconnect any subscriber which receives a not OK response when writing to its socket

include/ngx_http_push_stream_module_version.h

@@ -27,6 +27,6 @@
 #define NGX_HTTP_PUSH_STREAM_MODULE_VERSION_H_
 
 static const ngx_str_t  NGX_HTTP_PUSH_STREAM_TAG = ngx_string("0.3.2");
-static const ngx_str_t  NGX_HTTP_PUSH_STREAM_COMMIT = ngx_string("6796034c6ae6b627d0f31e613287a425f22dd97a");
+static const ngx_str_t  NGX_HTTP_PUSH_STREAM_COMMIT = ngx_string("73e503c8a3f678dabd55a93a23a226c7730fa7be");
 
 #endif /* NGX_HTTP_PUSH_STREAM_MODULE_VERSION_H_ */

src/ngx_http_push_stream_module_ipc.c

@@ -414,7 +414,7 @@ ngx_http_push_stream_respond_to_subscribers(ngx_http_push_stream_channel_t *chan
 
                 cur = prev;
             } else {
-                if (ngx_http_push_stream_send_response_message(subscriber->request, channel, msg) == NGX_ERROR) {
+                if (ngx_http_push_stream_send_response_message(subscriber->request, channel, msg) != NGX_OK) {
                     ngx_http_push_stream_queue_elem_t *prev = (ngx_http_push_stream_queue_elem_t *) ngx_queue_prev(&cur->queue);
                     ngx_http_push_stream_send_response_finalize(subscriber->request);
                     cur = prev;

src/ngx_http_push_stream_module_utils.c

@@ -946,7 +946,7 @@ ngx_http_push_stream_ping_timer_wake_handler(ngx_event_t *ev)
         rc = ngx_http_push_stream_send_response_message(r, NULL, ngx_http_push_stream_ping_msg);
     }
 
-    if (rc == NGX_ERROR) {
+    if (rc != NGX_OK) {
         ngx_http_push_stream_send_response_finalize(r);
     } else {
         ngx_http_push_stream_subscriber_ctx_t *ctx = ngx_http_get_module_ctx(r, ngx_http_push_stream_module);