Class: Async::HTTP::Body::Statistics
- Inherits:
-
Protocol::HTTP::Body::Wrapper
- Object
- Protocol::HTTP::Body::Wrapper
- Async::HTTP::Body::Statistics
- Defined in:
- lib/async/http/statistics.rb
Overview
Invokes a callback once the body has finished reading.
Instance Attribute Summary collapse
-
#end_time ⇒ Object
readonly
Returns the value of attribute end_time.
-
#first_chunk_time ⇒ Object
readonly
Returns the value of attribute first_chunk_time.
-
#sent ⇒ Object
readonly
Returns the value of attribute sent.
-
#start_time ⇒ Object
readonly
Returns the value of attribute start_time.
Instance Method Summary collapse
- #close(error = nil) ⇒ Object
- #first_chunk_duration ⇒ Object
-
#initialize(start_time, body, callback) ⇒ Statistics
constructor
A new instance of Statistics.
- #inspect ⇒ Object
- #read ⇒ Object
- #to_s ⇒ Object
- #total_duration ⇒ Object
Constructor Details
#initialize(start_time, body, callback) ⇒ Statistics
Returns a new instance of Statistics.
50 51 52 53 54 55 56 57 58 59 60 |
# File 'lib/async/http/statistics.rb', line 50 def initialize(start_time, body, callback) super(body) @sent = 0 @start_time = start_time @first_chunk_time = nil @end_time = nil @callback = callback end |
Instance Attribute Details
#end_time ⇒ Object (readonly)
Returns the value of attribute end_time.
64 65 66 |
# File 'lib/async/http/statistics.rb', line 64 def end_time @end_time end |
#first_chunk_time ⇒ Object (readonly)
Returns the value of attribute first_chunk_time.
63 64 65 |
# File 'lib/async/http/statistics.rb', line 63 def first_chunk_time @first_chunk_time end |
#sent ⇒ Object (readonly)
Returns the value of attribute sent.
66 67 68 |
# File 'lib/async/http/statistics.rb', line 66 def sent @sent end |
#start_time ⇒ Object (readonly)
Returns the value of attribute start_time.
62 63 64 |
# File 'lib/async/http/statistics.rb', line 62 def start_time @start_time end |
Instance Method Details
#close(error = nil) ⇒ Object
80 81 82 83 84 |
# File 'lib/async/http/statistics.rb', line 80 def close(error = nil) complete_statistics(error) super end |
#first_chunk_duration ⇒ Object
74 75 76 77 78 |
# File 'lib/async/http/statistics.rb', line 74 def first_chunk_duration if @first_chunk_time @first_chunk_time - @start_time end end |
#inspect ⇒ Object
112 113 114 |
# File 'lib/async/http/statistics.rb', line 112 def inspect "#{super} | \#<#{self.class} #{self.to_s}>" end |
#read ⇒ Object
86 87 88 89 90 91 92 93 94 95 96 |
# File 'lib/async/http/statistics.rb', line 86 def read chunk = super @first_chunk_time ||= Clock.now if chunk @sent += chunk.bytesize end return chunk end |
#to_s ⇒ Object
98 99 100 101 102 103 104 105 106 107 108 109 110 |
# File 'lib/async/http/statistics.rb', line 98 def to_s parts = ["sent #{@sent} bytes"] if duration = self.total_duration parts << "took #{format_duration(duration)} in total" end if duration = self.first_chunk_duration parts << "took #{format_duration(duration)} until first chunk" end return parts.join('; ') end |
#total_duration ⇒ Object
68 69 70 71 72 |
# File 'lib/async/http/statistics.rb', line 68 def total_duration if @end_time @end_time - @start_time end end |