# File lib/thrift/transport/http_client_transport.rb, line 28 def initialize(url) @url = URI url @headers = {'Content-Type' => 'application/x-thrift'} @outbuf = "" end
# File lib/thrift/transport/http_client_transport.rb, line 38 def add_headers(headers) @headers = @headers.merge(headers) end
# File lib/thrift/transport/http_client_transport.rb, line 42 def flush http = Net::HTTP.new @url.host, @url.port http.use_ssl = @url.scheme == "https" resp, data = http.post(@url.request_uri, @outbuf, @headers) @inbuf = StringIO.new data @outbuf = "" end
# File lib/thrift/transport/http_client_transport.rb, line 34 def open?; true end
# File lib/thrift/transport/http_client_transport.rb, line 35 def read(sz); @inbuf.read sz end
# File lib/thrift/transport/http_client_transport.rb, line 36 def write(buf); @outbuf << buf end