Project

channel

0.0
No commit activity in last 3 years
No release in over 3 years
Simple native Channel object for Ruby MRI (1.8.{6,7} and 1.9.2)
2005
2006
2007
2008
2009
2010
2011
2012
2013
2014
2015
2016
2017
2018
2019
2020
2021
2022
2023
2024
2025
 Dependencies
 Project Readme
Simple native Channel object for Ruby MRI
  (c) 2009 Lourens Naudé (methodmissing), James Tucker (raggi) 
 
  http://github.com/methodmissing/channel

This library works with Ruby 1.8 and 1.9 and is a more efficient
implementation of the following Ruby code :

  class RubyChannel
    def initialize
      @subscribers = []
    end
    def subscribe(&b)
      @subscribers << b
      self
    end
    def <<(o)
      @subscribers.each { |s| s.call(o) }
    end
  end

Use cases :

  * In process message dispatch
  * Parsers and protocols with a message, error and warning channel 
  * Facilitates decoupled notification and callback patterns

Caveats :

  * Fixed width channel size for very thin, and fast, subscriber management

Examples :

  counter = 0
  ch = Channel.new.subscribe{|obj| counter += obj }
  ch << 3
  ch << -2
  counter #=> 1  

Todo :
  
  * A deferrable mode that notifies on a background thread (pending 1.9)
  * More flexible notification mechanism through integration with http://github.com/methodmissing/callback/tree/master 
  * Filters

To run the test suite:

  rake

To run the benchmarks:

  rake bench