Module: Thrift::Processor

Defined in:
lib/thrift_client/thrift.rb,
lib/thrift_client/multiplexed_processor.rb

Instance Method Summary collapse

Instance Method Details

#write_result(result, oprot, name, seqid) ⇒ Object



61
62
63
64
65
66
67
68
69
70
# File 'lib/thrift_client/thrift.rb', line 61

def write_result(result, oprot, name, seqid)
  if @service
    oprot.write_message_begin(@service + ':' + name, MessageTypes::REPLY, seqid)
  else
    oprot.write_message_begin(name, MessageTypes::REPLY, seqid)
  end
  result.write(oprot)
  oprot.write_message_end
  oprot.trans.flush
end