Class: Nervion::Client

Inherits:

Object

• Object
• Nervion::Client

Defined in:

lib/nervion/client.rb

Instance Method Summary

• #initialize(host, port) ⇒ Client constructor

  A new instance of Client.

• #stop ⇒ Object
• #stream(request, callbacks) ⇒ Object

Constructor Details

#initialize(host, port) ⇒ Client

Returns a new instance of Client.

# File 'lib/nervion/client.rb', line 8

def initialize(host, port)
  @host = host
  @port = port
end

Instance Method Details

#stop ⇒ Object

# File 'lib/nervion/client.rb', line 18

def stop
  @stream_handler.close_stream
  EM.stop
end

#stream(request, callbacks) ⇒ Object

# File 'lib/nervion/client.rb', line 13

def stream(request, callbacks)
  @stream_handler = StreamHandler.new(callbacks)
  EM.run { EM.connect @host, @port, Stream, request, @stream_handler }
end