Method: EM::Mongo::EMConnection#message_headers
- Defined in:
- lib/em-mongo/connection.rb
#message_headers(operation, request_id, message) ⇒ Object
90 91 92 93 94 95 96 97 |
# File 'lib/em-mongo/connection.rb', line 90 def (operation, request_id, ) headers = BSON::ByteBuffer.new headers.put_int(16 + .size) headers.put_int(request_id) headers.put_int(0) headers.put_int(operation) headers end |