Sha256: 3c5250c72766fc144056106475afabf4a3441ecce277660d4b1d895e7f7b1979

Contents?: true

Size: 538 Bytes

Versions: 70

Compression:

Stored size: 538 Bytes

Contents

module Protobuf
  module Rpc
    class EventedRunner

      def self.stop
        ::EventMachine.stop_event_loop if ::EventMachine.reactor_running?
      end

      def self.run(options)
        # Startup and run the rpc server
        ::EventMachine.schedule do
          ::EventMachine.start_server(options[:host], options[:port], ::Protobuf::Rpc::Evented::Server)
        end

        # Join or start the reactor
				yield if block_given?
        ::EM.reactor_running? ? ::EM.reactor_thread.join : ::EM.run
      end
    end
  end
end

Version data entries

70 entries across 70 versions & 1 rubygems

Version Path
protobuf-2.7.2-java lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.7.2 lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.7.1-java lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.7.1 lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.7.0-java lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.7.0 lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.7.0.rc1-java lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.7.0.rc1 lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.6.6-java lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.6.6 lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.6.5-java lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.6.5 lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.6.4-java lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.6.4 lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.6.3-java lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.6.3 lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.6.2-java lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.6.2 lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.6.1-java lib/protobuf/rpc/servers/evented_runner.rb
protobuf-2.6.1 lib/protobuf/rpc/servers/evented_runner.rb