Class: Neo4j::Core::CypherSession::Adaptors::Bolt::Job

Inherits:
Object
  • Object
show all
Defined in:
lib/neo4j/core/cypher_session/adaptors/bolt.rb

Overview

Represents a set of messages to send to the server

Instance Method Summary collapse

Constructor Details

#initialize(session) ⇒ Job

Returns a new instance of Job.



284
285
286
287
 
# File 'lib/neo4j/core/cypher_session/adaptors/bolt.rb', line 284

def initialize(session)
  @messages = []
  @session = session
end

Instance Method Details

#add_message(type, *args) ⇒ Object 



289
290
291
 
# File 'lib/neo4j/core/cypher_session/adaptors/bolt.rb', line 289

def add_message(type, *args)
  @messages << Message.new(type, *args)
end

#chunked_packed_stream ⇒ Object 



293
294
295
296
297
298
299
300
301
302
303
 
# File 'lib/neo4j/core/cypher_session/adaptors/bolt.rb', line 293

def chunked_packed_stream
  io = ChunkWriterIO.new

  @messages.each do |message|
    io.write(message.packed_stream)
    io.flush(true)
  end

  io.rewind
  io.read
end

#to_s ⇒ Object 



305
306
307
 
# File 'lib/neo4j/core/cypher_session/adaptors/bolt.rb', line 305

def to_s
  @messages.join(' | ')
end