File tree Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -41,8 +41,11 @@ def initialize(framer, local_stream_id)
41
41
@dependencies = { 0 => @dependency }
42
42
43
43
@framer = framer
44
+
44
45
# The next stream id to use:
45
46
@local_stream_id = local_stream_id
47
+
48
+ # The biggest remote stream id seen thus far:
46
49
@remote_stream_id = 0
47
50
48
51
@local_settings = PendingSettings . new
@@ -438,14 +441,14 @@ def closed_stream_id?(id)
438
441
if @local_stream_id . even?
439
442
id < @local_stream_id
440
443
else
441
- id < @remote_stream_id
444
+ id <= @remote_stream_id
442
445
end
443
446
elsif id . odd?
444
447
# Client-initiated streams are odd.
445
448
if @local_stream_id . odd?
446
449
id < @local_stream_id
447
450
else
448
- id < @remote_stream_id
451
+ id <= @remote_stream_id
449
452
end
450
453
end
451
454
end
You can’t perform that action at this time.
0 commit comments