Method: Miu::Proxy#initialize

Defined in:
lib/miu/proxy.rb

#initialize(frontends, backends) ⇒ Proxy

Returns a new instance of Proxy.



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

def initialize(frontends, backends)
  @frontends = Array(frontends).map { |s| s.to_io rescue s }
  @backends = Array(backends).map { |s| s.to_io rescue s }

  @frontends.each { |s| s.instance_variable_set PROXY_TO, @backends }
  @backends.each { |s| s.instance_variable_set PROXY_TO, @frontends }

  @poller = ::ZMQ::Poller.new
  @frontends.each { |s| @poller.register_readable s }
  @backends.each { |s| @poller.register_readable s }
end