aboutsummaryrefslogtreecommitdiffstats
path: root/test
diff options
context:
space:
mode:
authorKazuki Yamaguchi <k@rhe.jp>2015-08-05 22:52:04 +0900
committerKazuki Yamaguchi <k@rhe.jp>2015-08-05 22:52:04 +0900
commit2118f5bf3ccbacc060b9d2502934119b04e184f0 (patch)
tree22dc1e31a7c59a575f2fb15734912315d33239ae /test
parent06608a0cab5fd7f6e319b4954e2bf8d52f37ae72 (diff)
downloadplum-2118f5bf3ccbacc060b9d2502934119b04e184f0.tar.gz
stream: split user APIs into StreamHelper
Diffstat (limited to 'test')
-rw-r--r--test/plum/test_stream.rb23
-rw-r--r--test/plum/test_stream_helper.rb28
2 files changed, 28 insertions, 23 deletions
diff --git a/test/plum/test_stream.rb b/test/plum/test_stream.rb
index 9e0cebc..5379699 100644
--- a/test/plum/test_stream.rb
+++ b/test/plum/test_stream.rb
@@ -165,29 +165,6 @@ class StreamTest < Minitest::Test
}
end
- def test_stream_promise
- open_new_stream {|stream|
- push_stream = stream.promise([])
-
- assert(push_stream.id % 2 == 0)
- assert(push_stream.id > stream.id)
- assert_equal(stream, push_stream.parent)
- assert_includes(stream.children, push_stream)
- }
- end
-
- def test_stream_window_update
- open_new_stream {|stream|
- before_ws = stream.recv_remaining_window
- stream.window_update(500)
-
- last = sent_frames.last
- assert_equal(:window_update, last.type)
- assert_equal(500, last.payload.uint32)
- assert_equal(before_ws + 500, stream.recv_remaining_window)
- }
- end
-
def test_stream_close
open_new_stream(:half_closed_local) {|stream|
stream.close(StreamError.new(:frame_size_error).http2_error_code)
diff --git a/test/plum/test_stream_helper.rb b/test/plum/test_stream_helper.rb
new file mode 100644
index 0000000..eebfbea
--- /dev/null
+++ b/test/plum/test_stream_helper.rb
@@ -0,0 +1,28 @@
+require "test_helper"
+
+using BinaryString
+
+class StreamHelperTest < Minitest::Test
+ def test_stream_window_update
+ open_new_stream {|stream|
+ before_ws = stream.recv_remaining_window
+ stream.window_update(500)
+
+ last = sent_frames.last
+ assert_equal(:window_update, last.type)
+ assert_equal(500, last.payload.uint32)
+ assert_equal(before_ws + 500, stream.recv_remaining_window)
+ }
+ end
+
+ def test_stream_promise
+ open_new_stream {|stream|
+ push_stream = stream.promise([])
+
+ assert(push_stream.id % 2 == 0)
+ assert(push_stream.id > stream.id)
+ assert_equal(stream, push_stream.parent)
+ assert_includes(stream.children, push_stream)
+ }
+ end
+end