File tree Expand file tree Collapse file tree 4 files changed +6
-6
lines changed
rxjava-clojure/src/main/java/rx/lang/clojure
rxjava-groovy/src/main/java/rx/lang/groovy
rxjava-jruby/src/main/java/rx/lang/jruby
rxjava-core/src/main/java/rx/util Expand file tree Collapse file tree 4 files changed +6
-6
lines changed Original file line number Diff line number Diff line change 13
13
* See the License for the specific language governing permissions and
14
14
* limitations under the License.
15
15
*/
16
- package org . rx .lang .clojure ;
16
+ package rx .lang .clojure ;
17
17
18
18
import java .util .Arrays ;
19
19
@@ -100,7 +100,7 @@ public void before() {
100
100
101
101
@ Test
102
102
public void testTake () {
103
- runClojureScript ("(-> (org. rx.reactive .Observable/toObservable [\" one\" \" two\" \" three\" ]) (.take 2) (.subscribe (fn [arg] (println arg))))" );
103
+ runClojureScript ("(-> (rx.observables .Observable/toObservable [\" one\" \" two\" \" three\" ]) (.take 2) (.subscribe (fn [arg] (println arg))))" );
104
104
}
105
105
106
106
// commented out for now as I can't figure out how to set the var 'a' with the 'assertion' instance when running the code from java
Original file line number Diff line number Diff line change 13
13
* See the License for the specific language governing permissions and
14
14
* limitations under the License.
15
15
*/
16
- package org . rx .lang .groovy ;
16
+ package rx .lang .groovy ;
17
17
18
18
import static org .mockito .Matchers .*;
19
19
import static org .mockito .Mockito .*;
Original file line number Diff line number Diff line change 13
13
* See the License for the specific language governing permissions and
14
14
* limitations under the License.
15
15
*/
16
- package org . rx .lang .jruby ;
16
+ package rx .lang .jruby ;
17
17
18
18
import static org .mockito .Matchers .*;
19
19
import static org .mockito .Mockito .*;
@@ -163,7 +163,7 @@ private void runGroovyScript(String script) {
163
163
164
164
StringBuilder b = new StringBuilder ();
165
165
// force JRuby to always use subscribe(Object)
166
- b .append ("import org. rx.reactive .Observable" ).append ("\n " );
166
+ b .append ("import \" rx.observables .Observable\" " ).append ("\n " );
167
167
b .append ("class Observable" ).append ("\n " );
168
168
b .append (" java_alias :subscribe, :subscribe, [java.lang.Object]" ).append ("\n " );
169
169
b .append ("end" ).append ("\n " );
Original file line number Diff line number Diff line change @@ -44,7 +44,7 @@ public class Functions {
44
44
}
45
45
46
46
private static void loadLanguageAdaptor (String name ) {
47
- String className = "org. rx.lang." + name .toLowerCase () + "." + name + "Adaptor" ;
47
+ String className = "rx.lang." + name .toLowerCase () + "." + name + "Adaptor" ;
48
48
try {
49
49
Class <?> c = Class .forName (className );
50
50
FunctionLanguageAdaptor a = (FunctionLanguageAdaptor ) c .newInstance ();
You can’t perform that action at this time.
0 commit comments