Class: Flatware::Socket::Monitor

Inherits:
Object
  • Object
show all
Defined in:
lib/flatware/socket.rb

Instance Method Summary collapse

Constructor Details

#initialize(port) ⇒ Monitor

Returns a new instance of Monitor.



123
124
125
126
 
# File 'lib/flatware/socket.rb', line 123

def initialize(port)
  @socket = Flatware.socket ZMQ::PAIR
  @socket.connect port
end

Instance Method Details

#recv ⇒ Object 



128
129
130
131
132
 
# File 'lib/flatware/socket.rb', line 128

def recv
  bytes = @socket.recv marshal: false
  data = LibZMQ::EventData.new FFI::MemoryPointer.from_string bytes
  event[data.event]
end