Module: Evilution::Parallel::WorkQueue::Channel

Defined in:
lib/evilution/parallel/work_queue/channel.rb

Defined Under Namespace

Modules: Frame

Class Method Summary collapse

Class Method Details

.read(io) ⇒ Object 



13
14
15
16
17
18
19
20
 
# File 'lib/evilution/parallel/work_queue/channel.rb', line 13

def read(io)
  header = io.read(4)
  return nil if header.nil? || header.bytesize < 4

  length = header.unpack1("N")
  payload = io.read(length)
  Frame.decode(header, payload)
end

.write(io, object) ⇒ Object 



8
9
10
11
 
# File 'lib/evilution/parallel/work_queue/channel.rb', line 8

def write(io, object)
  io.write(Frame.encode(object))
  io.flush
end