Sha256: e8160563acb4b4bebccbe167648091ad7ba5178419700f92e7bbe4650753de4a
Contents?: true
Size: 1.42 KB
Versions: 1
Compression:
Stored size: 1.42 KB
Contents
# encoding: utf-8 module Hatetepe module Support module Message def closed? !body.closed.pending? end def closed! body.closed.sync end def closed(&block) body.closed.then(&block) end def close body.closed.fulfill end def reject_closed(reason) body.closed.reject(reason) end def add_extra_headers(extra) extra.each { |k, v| headers.key?(k) || headers[k] = v } end def self.build(parser) if parser.http_method build_request(parser) else build_response(parser) end end private def self.build_request(parser) request = Request.new(http_method_from(parser), parser.request_url, parser.headers, Body.new) request.http_version = http_version_from(parser) request end def self.build_response(parser) response = Response.new(parser.status_code, parser.headers, Body.new) response.http_version = http_version_from(parser) response end def self.http_method_from(parser) parser.http_method.downcase.to_sym end def self.http_version_from(parser) parser.http_version.join('.').to_f end end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
hatetepe-0.6.0.pre.2 | lib/hatetepe/support/message.rb |