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.



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

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

Instance Method Details

#add_message(type, *args) ⇒ Object 



308
309
310
 
# File 'lib/neo4j/core/cypher_session/adaptors/bolt.rb', line 308

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

#chunked_packed_stream ⇒ Object 



312
313
314
315
316
317
318
319
320
321
322
 
# File 'lib/neo4j/core/cypher_session/adaptors/bolt.rb', line 312

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 



324
325
326
 
# File 'lib/neo4j/core/cypher_session/adaptors/bolt.rb', line 324

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