0.0
No release in over a year
This is an implementation of the Reactor pattern described in [Pattern-Oriented Software Architecture (Volume 2)][POSA2]. It allows an asynchronous application to be described as one or more "reactions" to events, in this case either I/O conditions on a ZMQ socket or a timer expiring. A simple example: # Start a SERVER socket, and print out any messages sent to it reactor = CZTop::Reactor.new socket = CZTop::Socket::SERVER.new socket.bind( 'tcp://0.0.0.0:8' ) reactor.register( socket, :read ) do |event| if event.readable? message = event.socket.receive puts "Read: %p" % [ message.to_a ] end end reactor.start_polling
2005
2006
2007
2008
2009
2010
2011
2012
2013
2014
2015
2016
2017
2018
2019
2020
2021
 Dependencies

Development

Runtime

~> 0.13
~> 4.1