HelloRx.rb

load_assembly 'System.Core'
load_assembly 'System.CoreEx, Version=1.0.2521.104, Culture=neutral, PublicKeyToken=31bf3856ad364e35'
load_assembly 'System.Reactive, Version=1.0.2521.104, Culture=neutral, PublicKeyToken=31bf3856ad364e35'

using_clr_extensions System
using_clr_extensions System::Linq

include System
include System::Linq

class Object
  def to_seq(type = Object)
    System::Linq::Enumerable.method(:of_type).of(type).call(self.to_a)
  end
end

range = (1..10).to_seq
observable = 
	Observable.to_observable(range).where(lambda {|next_val| next_val % 2 == 0})
	
dispoable = observable.subscribe(Action[Object].new {|val| puts "Next value: #{val}" })