Class: Neo4j::Core::CypherSession::Adaptors::Bolt::Job
- Inherits:
-
Object
- Object
- Neo4j::Core::CypherSession::Adaptors::Bolt::Job
- 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
- #add_message(type, *args) ⇒ Object
- #chunked_packed_stream ⇒ Object
-
#initialize(session) ⇒ Job
constructor
A new instance of Job.
- #to_s ⇒ Object
Constructor Details
#initialize(session) ⇒ Job
Returns a new instance of Job.
310 311 312 313 |
# File 'lib/neo4j/core/cypher_session/adaptors/bolt.rb', line 310 def initialize(session) @messages = [] @session = session end |
Instance Method Details
#add_message(type, *args) ⇒ Object
315 316 317 |
# File 'lib/neo4j/core/cypher_session/adaptors/bolt.rb', line 315 def (type, *args) @messages << Message.new(type, *args) end |
#chunked_packed_stream ⇒ Object
319 320 321 322 323 324 325 326 327 328 329 |
# File 'lib/neo4j/core/cypher_session/adaptors/bolt.rb', line 319 def chunked_packed_stream io = ChunkWriterIO.new @messages.each do || io.write(.packed_stream) io.flush(true) end io.rewind io.read end |
#to_s ⇒ Object
331 332 333 |
# File 'lib/neo4j/core/cypher_session/adaptors/bolt.rb', line 331 def to_s @messages.join(' | ') end |