Class: Falcon::Capybara::Wrapper

Inherits:
Object
  • Object
show all
Defined in:
lib/falcon/capybara/wrapper.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Wrapper

Returns a new instance of Wrapper.



29
30
31
32
33
34
 
# File 'lib/falcon/capybara/wrapper.rb', line 29

def initialize
  @job = nil
  
  @job_available = Async::IO::Notification.new
  @job_complete = Async::IO::Notification.new
end

Instance Method Details

#call(app, port, host) ⇒ Object 



51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
# File 'lib/falcon/capybara/wrapper.rb', line 51

def call(app, port, host)
  require 'async/reactor'
  require 'falcon/server'
  
  Async::Reactor.run do |task|
    server = Falcon::Server.new(app, Async::IO::Endpoint.tcp(host, port))
    
    task.async do
      Async.logger.debug (self) {"Running server..."}
      server.run
    end
    
    while true
      Async.logger.debug (self) {"Waiting for job..."}
      @job_available.wait while @job.nil?
      
      Async.logger.debug (self) {"Running job #{@job}"}
      @job.call
      @job = nil
    end
  end
end

#close ⇒ Object 



36
37
38
39
 
# File 'lib/falcon/capybara/wrapper.rb', line 36

def close
  @job_available.close
  @job_complete.close
end

#remote(&block) ⇒ Object 



41
42
43
44
45
46
47
48
49
 
# File 'lib/falcon/capybara/wrapper.rb', line 41

def remote(&block)
  @job = block
  @job_available.signal
  
  Async::Reactor.run do
    Async.logger.debug (self) {"Waiting for job completion..."}
    @job_complete.wait until @job.nil?
  end.wait
end