Commit 9bce6069 authored by Wandenberg's avatar Wandenberg

remove unecessary PING frame sent after publish a message

parent 3c65a1df
...@@ -320,7 +320,7 @@ describe "Subscriber WebSocket" do ...@@ -320,7 +320,7 @@ describe "Subscriber WebSocket" do
socket.print(frame) socket.print(frame)
body, dummy = read_response_on_socket(socket, "ch1") body, dummy = read_response_on_socket(socket, "ch1")
expect(body).to eql("\211\000\x81.{\"channel\":\"ch2\", \"id\":\"1\", \"message\":\"hello\"}\x81.{\"channel\":\"ch1\", \"id\":\"1\", \"message\":\"hello\"}") expect(body).to eql("\x81.{\"channel\":\"ch2\", \"id\":\"1\", \"message\":\"hello\"}\x81.{\"channel\":\"ch1\", \"id\":\"1\", \"message\":\"hello\"}")
socket.close socket.close
EventMachine.run do EventMachine.run do
......
...@@ -302,7 +302,6 @@ ngx_http_push_stream_websocket_reading(ngx_http_request_t *r) ...@@ -302,7 +302,6 @@ ngx_http_push_stream_websocket_reading(ngx_http_request_t *r)
goto finalize; goto finalize;
} }
} }
ngx_http_push_stream_send_response_text(r, NGX_HTTP_PUSH_STREAM_WEBSOCKET_PING_LAST_FRAME_BYTE, sizeof(NGX_HTTP_PUSH_STREAM_WEBSOCKET_PING_LAST_FRAME_BYTE), 1);
} }
if (ctx->temp_pool != NULL) { if (ctx->temp_pool != NULL) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment