We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ca97946 commit cee0d67Copy full SHA for cee0d67
lib/async/http/protocol/http1/finishable.rb
@@ -15,6 +15,8 @@ class Finishable < ::Protocol::HTTP::Body::Wrapper
15
def initialize(body)
16
super(body)
17
18
+ $stderr.puts "Finishable#initialize: #{body.inspect}"
19
+
20
@closed = Async::Variable.new
21
@error = nil
22
@@ -28,12 +30,16 @@ def reading?
28
30
def read
29
31
@reading = true
32
- super
33
+ super.tap do |chunk|
34
+ $stderr.puts "Finishable#read: #{chunk.inspect}"
35
+ end
36
end
37
38
def close(error = nil)
39
super
40
41
+ $stderr.puts "Finishable#close: #{error.inspect}"
42
43
unless @closed.resolved?
44
@error = error
45
@closed.value = true
0 commit comments