Contents

require 'rubygems'
require 'jretlang'

module Mailbox

  def self.included(base)
		base.extend(Mailbox::ClassMethods)
	end
	
	def register_channel(channel_name, channel)
		channel_registry = self.class.__channel_registry__
		channel_registry.each_pair { |key, value| __subscribe__(channel, key) if value == channel_name }
	end

	def __subscribe__(channel, method)
		channel.subscribe_on_fiber(__fiber__) { |*args| self.send(method, *args) }
	end

  def __started_fiber__
  	fiber = JRL::Fiber.new
  	fiber.start
  	fiber
  end

  def __fiber__
  	@fiber ||= __started_fiber__
  end 

	module ClassMethods

 		attr_accessor :__channel_registry__

  	def mailslot(params={})
			@next_channel_name = params[:channel]
			@mailslot = true
  	end

  	def method_added(method_name, &block)
  		return if @adding_mailbox_to_method == method_name

  		unless @mailslot == true
  		  private method_name
  			return
  		end

  		@mailslot = false

			if @next_channel_name.nil?
				__setup_on_fiber__(method_name)
			else
				__setup_on_channel__(method_name)
			end

  	end

		def __setup_on_fiber__(method_name)
  		alias_method :"__#{method_name}__", method_name

  		@adding_mailbox_to_method = method_name

			define_method( method_name, lambda do |*args| 
				__fiber__.execute { self.send(:"__#{method_name}__", *args ) }  
			end )

  		@adding_mailbox_to_method = nil
		end

		def __setup_on_channel__(method_name)
			private method_name
			@__channel_registry__ ||= {}
			__channel_registry__[method_name] = @next_channel_name
			@next_channel_name = nil
		end

	end 
	
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
mailbox-0.1.0	lib/mailbox.rb
mailbox-0.0.0	lib/mailbox.rb