Method: Pollen::Executor#accept

Defined in:
lib/pollen/server.rb

#accept(connection) ⇒ Object



26
27
28
29
30
31
# File 'lib/pollen/server.rb', line 26

def accept(connection)
  Rails.logger.info "Creating connection for stream #{connection.stream_id}"
  @mutex.synchronize do
    @incoming << connection
  end
end