diff options
Diffstat (limited to 'test/plum/stream/test_handle_frame.rb')
| -rw-r--r-- | test/plum/stream/test_handle_frame.rb | 54 |
1 files changed, 27 insertions, 27 deletions
diff --git a/test/plum/stream/test_handle_frame.rb b/test/plum/stream/test_handle_frame.rb index b4b4a4c..2c14c26 100644 --- a/test/plum/stream/test_handle_frame.rb +++ b/test/plum/stream/test_handle_frame.rb @@ -6,9 +6,9 @@ class StreamHandleFrameTest < Minitest::Test ## DATA def test_stream_handle_data payload = "ABC" * 5 - open_new_stream(state: :open) {|stream| + open_new_stream(state: :open) { |stream| data = nil - stream.connection.on(:data) {|_, _data| data = _data } + stream.connection.on(:data) { |_, _data| data = _data } stream.receive_frame(Frame.new(type: :data, stream_id: stream.id, flags: [], payload: payload)) assert_equal(payload, data) @@ -17,9 +17,9 @@ class StreamHandleFrameTest < Minitest::Test def test_stream_handle_data_padded payload = "ABC" * 5 - open_new_stream(state: :open) {|stream| + open_new_stream(state: :open) { |stream| data = nil - stream.connection.on(:data) {|_, _data| data = _data } + stream.connection.on(:data) { |_, _data| data = _data } stream.receive_frame(Frame.new(type: :data, stream_id: stream.id, flags: [:padded], payload: "".push_uint8(6).push(payload).push("\x00"*6))) assert_equal(payload, data) @@ -28,7 +28,7 @@ class StreamHandleFrameTest < Minitest::Test def test_stream_handle_data_too_long_padding payload = "ABC" * 5 - open_new_stream(state: :open) {|stream| + open_new_stream(state: :open) { |stream| assert_connection_error(:protocol_error) { stream.receive_frame(Frame.new(type: :data, stream_id: stream.id, flags: [:padded], payload: "".push_uint8(100).push(payload).push("\x00"*6))) @@ -38,7 +38,7 @@ class StreamHandleFrameTest < Minitest::Test def test_stream_handle_data_end_stream payload = "ABC" * 5 - open_new_stream(state: :open) {|stream| + open_new_stream(state: :open) { |stream| stream.receive_frame(Frame.new(type: :data, stream_id: stream.id, flags: [:end_stream], payload: payload)) assert_equal(:half_closed_remote, stream.state) @@ -47,7 +47,7 @@ class StreamHandleFrameTest < Minitest::Test def test_stream_handle_data_invalid_state payload = "ABC" * 5 - open_new_stream(state: :half_closed_remote) {|stream| + open_new_stream(state: :half_closed_remote) { |stream| assert_stream_error(:stream_closed) { stream.receive_frame(Frame.new(type: :data, stream_id: stream.id, flags: [:end_stream], payload: payload)) @@ -57,9 +57,9 @@ class StreamHandleFrameTest < Minitest::Test ## HEADERS def test_stream_handle_headers_single - open_new_stream {|stream| + open_new_stream { |stream| headers = nil - stream.connection.on(:headers) {|_, _headers| + stream.connection.on(:headers) { |_, _headers| headers = _headers } stream.receive_frame(Frame.new(type: :headers, @@ -72,10 +72,10 @@ class StreamHandleFrameTest < Minitest::Test end def test_stream_handle_headers_continuation - open_new_stream {|stream| + open_new_stream { |stream| payload = HPACK::Encoder.new(0).encode([[":path", "/"]]) headers = nil - stream.connection.on(:headers) {|_, _headers| + stream.connection.on(:headers) { |_, _headers| headers = _headers } stream.receive_frame(Frame.new(type: :headers, @@ -93,10 +93,10 @@ class StreamHandleFrameTest < Minitest::Test end def test_stream_handle_headers_padded - open_new_stream {|stream| + open_new_stream { |stream| payload = HPACK::Encoder.new(0).encode([[":path", "/"]]) headers = nil - stream.connection.on(:headers) {|_, _headers| + stream.connection.on(:headers) { |_, _headers| headers = _headers } stream.receive_frame(Frame.new(type: :headers, @@ -108,7 +108,7 @@ class StreamHandleFrameTest < Minitest::Test end def test_stream_handle_headers_too_long_padding - open_new_stream {|stream| + open_new_stream { |stream| payload = HPACK::Encoder.new(0).encode([[":path", "/"]]) assert_connection_error(:protocol_error) { stream.receive_frame(Frame.new(type: :headers, @@ -120,7 +120,7 @@ class StreamHandleFrameTest < Minitest::Test end def test_stream_handle_headers_broken - open_new_stream {|stream| + open_new_stream { |stream| payload = "\x00\x01\x02" assert_connection_error(:compression_error) { stream.receive_frame(Frame.new(type: :headers, @@ -133,17 +133,17 @@ class StreamHandleFrameTest < Minitest::Test def test_stream_handle_headers_state _payload = HPACK::Encoder.new(0).encode([[":path", "/"]]) - open_new_stream(state: :reserved_local) {|stream| + open_new_stream(state: :reserved_local) { |stream| assert_connection_error(:protocol_error) { stream.receive_frame(Frame.new(type: :headers, stream_id: stream.id, flags: [:end_headers, :end_stream], payload: _payload)) } } - open_new_stream(state: :closed) {|stream| + open_new_stream(state: :closed) { |stream| assert_connection_error(:stream_closed) { stream.receive_frame(Frame.new(type: :headers, stream_id: stream.id, flags: [:end_headers, :end_stream], payload: _payload)) } } - open_new_stream(state: :half_closed_remote) {|stream| + open_new_stream(state: :half_closed_remote) { |stream| assert_stream_error(:stream_closed) { stream.receive_frame(Frame.new(type: :headers, stream_id: stream.id, flags: [:end_headers, :end_stream], payload: _payload)) } @@ -151,12 +151,12 @@ class StreamHandleFrameTest < Minitest::Test end def test_stream_handle_headers_priority - open_server_connection {|con| + open_server_connection { |con| parent = open_new_stream(con) stream = open_new_stream(con) headers = nil - stream.connection.on(:headers) {|_, _headers| headers = _headers } + stream.connection.on(:headers) { |_, _headers| headers = _headers } header_block = HPACK::Encoder.new(0).encode([[":path", "/"]]) payload = "".push_uint32((1 << 31) | parent.id) .push_uint8(50) @@ -174,7 +174,7 @@ class StreamHandleFrameTest < Minitest::Test ## PRIORITY def test_stream_handle_priority - open_server_connection {|con| + open_server_connection { |con| parent = open_new_stream(con) stream = open_new_stream(con) @@ -190,7 +190,7 @@ class StreamHandleFrameTest < Minitest::Test end def test_stream_handle_priority_self_depend - open_server_connection {|con| + open_server_connection { |con| stream = open_new_stream(con) payload = "".push_uint32((0 << 31) | stream.id).push_uint8(6) stream.receive_frame(Frame.new(type: :priority, @@ -203,7 +203,7 @@ class StreamHandleFrameTest < Minitest::Test end def test_stream_handle_priority_exclusive - open_server_connection {|con| + open_server_connection { |con| parent = open_new_stream(con) stream0 = open_new_stream(con, parent: parent) stream1 = open_new_stream(con, parent: parent) @@ -220,7 +220,7 @@ class StreamHandleFrameTest < Minitest::Test end def test_stream_handle_frame_size_error - open_new_stream {|stream| + open_new_stream { |stream| assert_stream_error(:frame_size_error) { stream.receive_frame(Frame.new(type: :priority, stream_id: stream.id, @@ -231,7 +231,7 @@ class StreamHandleFrameTest < Minitest::Test ## RST_STREAM def test_stream_handle_rst_stream - open_new_stream(state: :reserved_local) {|stream| + open_new_stream(state: :reserved_local) { |stream| stream.receive_frame(Frame.new(type: :rst_stream, stream_id: stream.id, payload: "\x00\x00\x00\x00")) @@ -240,7 +240,7 @@ class StreamHandleFrameTest < Minitest::Test end def test_stream_handle_rst_stream_idle - open_new_stream(state: :idle) {|stream| + open_new_stream(state: :idle) { |stream| assert_connection_error(:protocol_error) { stream.receive_frame(Frame.new(type: :rst_stream, stream_id: stream.id, @@ -250,7 +250,7 @@ class StreamHandleFrameTest < Minitest::Test end def test_stream_handle_rst_stream_frame_size - open_new_stream(state: :reserved_local) {|stream| + open_new_stream(state: :reserved_local) { |stream| assert_connection_error(:frame_size_error) { stream.receive_frame(Frame.new(type: :rst_stream, stream_id: stream.id, |