class Neo4j::Core::CypherSession::Adaptors::Bolt::Job

Represents a set of messages to send to the server

Public Class Methods

new(session) click to toggle source
    # File lib/neo4j/core/cypher_session/adaptors/bolt.rb
284 def initialize(session)
285   @messages = []
286   @session = session
287 end

Public Instance Methods

add_message(type, *args) click to toggle source
    # File lib/neo4j/core/cypher_session/adaptors/bolt.rb
289 def add_message(type, *args)
290   @messages << Message.new(type, *args)
291 end
chunked_packed_stream() click to toggle source
    # File lib/neo4j/core/cypher_session/adaptors/bolt.rb
293 def chunked_packed_stream
294   io = ChunkWriterIO.new
295 
296   @messages.each do |message|
297     io.write(message.packed_stream)
298     io.flush(true)
299   end
300 
301   io.rewind
302   io.read
303 end
to_s() click to toggle source
    # File lib/neo4j/core/cypher_session/adaptors/bolt.rb
305 def to_s
306   @messages.join(' | ')
307 end