Class: Reactomatic::TcpServer

Inherits:
Object
  • Object
show all
Defined in:
lib/reactomatic/tcp_server.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(opts = {}) ⇒ TcpServer 



5
6
7
8
 
# File 'lib/reactomatic/tcp_server.rb', line 5

def initialize(opts = {})
  @opts = opts
  @reactor = opts[:reactor] || Reactomatic.reactor
end

Instance Attribute Details

#reactor ⇒ Object

Returns the value of attribute reactor.



3
4
5
 
# File 'lib/reactomatic/tcp_server.rb', line 3

def reactor
  @reactor
end

Instance Method Details

#close ⇒ Object 



23
24
25
26
27
28
29
30
31
 
# File 'lib/reactomatic/tcp_server.rb', line 23

def close
  if @socket
    @reactor.deregister(@socket)
    @socket.close
    @socket = nil
  end

  nil
end

#listen(host, port, klass) ⇒ Object

Raises:



10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/reactomatic/tcp_server.rb', line 10

def listen(host, port, klass)
  raise AlreadyStarted if @server

  @host = host
  @port = port
  @klass = klass

  @socket = TCPServer.new(@host, @port)
  @reactor.register(@socket, :r, method(:selected))

  nil
end