Eventkit::Eventloop
A basic event loop implemented with Ruby's IO.select to perform non blocking IO.
Installation
Add this line to your application's Gemfile:
gem 'eventkit-eventloop'Event Loop Usage
Eventkit provides a basic event loop on top of Ruby's IO.select. Callbacks can be registered to monitor the readability or writability of IO objects. These callbacks are executed when the IO object is ready to be read or written to.
Another feature is timers, which allows you to execute code at some point in the future.
require 'eventkit/event_loop'
# Getting notified when an IO object is ready to be read or written
event_loop = Eventkit::EventLoop.new
server = TCPServer.new('localhost', 9595)
client = TCPSocket.new('localhost', 9595)
event_loop.register_read(server) do |server|
# This will be executed every time a new connection is ready to be accepted
connection, _ = server.accept_nonblock
event_loop.register_write(connection) do |connection|
bytes_written = connection.write_nonblock('hello world')
end
end
event_loop.start
# Unsubscribing from notifications
# A single read
event_loop.deregister_read(io_object, handler)
# A single write
event_loop.deregister_write(io_object, handler)
# All handlers
event_loop.deregister_write(io_object)
event_loop.deregister_read(io_object)
# Registering a handler to be run on the next tick
event_loop = Eventkit::EventLoop.new
event_loop.on_next_tick do
puts 'hello world'
event_loop.stop
end
event_loop.start
# Registering timers
event_loop = Eventkit::EventLoop.new
event_loop.register_timer(run_in: 5) do
# Block executes after 5 seconds have passed
puts 'hello world'
event_loop.stop
end
event_loop.startContributing
- Fork it ( https://github.com/[my-github-username]/eventkit-eventloop/fork )
- Create your feature branch (
git checkout -b my-new-feature) - Commit your changes (
git commit -am 'Add some feature') - Push to the branch (
git push origin my-new-feature) - Create a new Pull Request