diff options
author | Kazuki Yamaguchi <k@rhe.jp> | 2015-08-09 00:25:50 +0900 |
---|---|---|
committer | Kazuki Yamaguchi <k@rhe.jp> | 2015-08-09 00:25:50 +0900 |
commit | 3969a4bebf7737aec0484cbf4ac4d2ca3511b6b7 (patch) | |
tree | a2e99488844ccf108563a6e282284bc6ddbbb619 /lib/plum/flow_control.rb | |
parent | e2d18a67f6d9f8c78afe1eba769b9d474011bf6c (diff) | |
download | plum-3969a4bebf7737aec0484cbf4ac4d2ca3511b6b7.tar.gz |
implement "http" URIs support (currently only 'with prior knowledge')
Diffstat (limited to 'lib/plum/flow_control.rb')
-rw-r--r-- | lib/plum/flow_control.rb | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/lib/plum/flow_control.rb b/lib/plum/flow_control.rb index b62b39e..539ae8b 100644 --- a/lib/plum/flow_control.rb +++ b/lib/plum/flow_control.rb @@ -33,7 +33,7 @@ module Plum @send_remaining_window += diff consume_send_buffer - if ServerConnection === self + if Connection === self @streams.values.each do |stream| stream.update_send_initial_window_size(diff) end @@ -42,7 +42,7 @@ module Plum def update_recv_initial_window_size(diff) @recv_remaining_window += diff - if ServerConnection === self + if Connection === self @streams.values.each do |stream| stream.update_recv_initial_window_size(diff) end @@ -75,7 +75,7 @@ module Plum end end - def process_window_update(frame) + def receive_window_update(frame) if frame.length != 4 raise Plum::ConnectionError.new(:frame_size_error) end |