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