Handle OnSubscribeFuncs correctly in JRuby interop logic

OnSubscribeFunc#onSubscribe expects to return a Subscription. I am
unable to successfully cast the return value of a RubyProc, even if
that value _is_ an object that implements the Subscription interface,
into a Subscription in Java-land (Java reports that ConcreteJavaProxy
cannot be cast). Instead I allow JRuby to handle OnSubscribeFunc
arguments through its default proxy logic, which works correctly.

Author: Mike Ragalie

language-adaptors/rxjava-jruby/src/main/resources/rx/lang/jruby/interop.rb

@@ -3,7 +3,8 @@ module Lang
     module Jruby
       class Interop
         WRAPPERS = {
-          Java::RxUtilFunctions::Action => Java::RxLangJruby::JRubyActionWrapper
+          Java::RxUtilFunctions::Action         => Java::RxLangJruby::JRubyActionWrapper,
+          Java::Rx::Observable::OnSubscribeFunc => false
         }
 
         WRAPPERS.default = Java::RxLangJruby::JRubyFunctionWrapper
@@ -33,6 +34,9 @@ def initialize
                   type.ruby_class.ancestors.include?(java_class)
                 end
 
+                # Skip OnSubscribeFuncs
+                next if constructor && constructor.last == false
+
                 constructor = (constructor && constructor.last) || WRAPPERS.default
 
                 parameter_types[[method.name, method.static?]][idx] ||= []
@@ -52,7 +56,7 @@ def initialize
 
               klass_to_open = static ? klass.singleton_class : klass
 
-              [method_name, underscore(method_name)].each do |name|
+              [method_name, underscore(method_name)].uniq.each do |name|
                 klass_to_open.send(:alias_method, "#{name}_without_wrapping", name)
                 klass_to_open.send(:define_method, name) do |*args, &block|
                   context = RUNTIME.get_current_context

language-adaptors/rxjava-jruby/src/spec/ruby/rx/lang/jruby/interop_spec.rb

@@ -29,8 +29,18 @@
       observable.subscribe(1)
     end
 
+    it "doesn't wrap OnSubscribeFunc arguments" do
+      proc = lambda {|observer| observer.onNext("hi")}
+      Java::Rx::Observable.should_not_receive(:create_without_wrapping)
+      Java::Rx::Observable.create(proc).should be_a(Java::Rx::Observable)
+    end
+
     it "works with underscoreized method names" do
-      observable.should_receive(:finally_do_without_wrapping).with(kind_of(Java::RxLangJruby::JRubyActionWrapper))
+      observable.
+          should_receive(:finally_do_without_wrapping).
+          with(kind_of(Java::RxLangJruby::JRubyActionWrapper)).
+          and_call_original
+
       observable.finally_do(lambda {})
     end