Observable.rb

actions = {
	:on_next => proc {|next_value| puts "Next: #{next_value}" }, 
	:on_error => proc {|exception| puts "Exception: #{exception.message}"},
	:on_completed => proc { puts "done!" }	
}
observer = Observer.new actions

observable = Observable.range(2,2, Scheduler.new_thread).select_many do |x|
	Observable.range(x * 3, 3, Scheduler.new_thread)
end

observable.subscribe(observer)