Delay

CHANGES.md

@@ -1,5 +1,148 @@
 # RxJava Releases #
 
+### Version 0.15.1 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.15.1%22)) ###
+
+This release should be additive functionality and bug fixes.
+
+* [Pull 510](https://github.com/Netflix/RxJava/pull/506) Operators: And, Then, When
+* [Pull 514](https://github.com/Netflix/RxJava/pull/514) Operator: Join
+* [Pull 525](https://github.com/Netflix/RxJava/pull/526) Operators: toMap/toMultiMap
+* [Pull 510](https://github.com/Netflix/RxJava/pull/510) BugFix: Zip
+* [Pull 512](https://github.com/Netflix/RxJava/pull/512) Scala Adaptor Details
+* [Pull 512](https://github.com/Netflix/RxJava/pull/529) Scala fixes
+* [Pull 508](https://github.com/Netflix/RxJava/pull/508) Empty subscribe 
+* [Pull 522](https://github.com/Netflix/RxJava/pull/522) Unsubscribe from takeLast
+* [Pull 525](https://github.com/Netflix/RxJava/pull/525) BugFix: Handling of Terminal State for Behavior/Publish Subjects
+
+### Version 0.15.0 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.15.0%22)) ###
+
+This release contains a refactor of the Scala Bindings by @headinthebox that results in some breaking changes. 
+The previous solution ended up not working well in all cases for idiomatic Scala usage. Java/Scala interop has been changed and is no longer transparent so as to optimize for native Scala usage.
+Read the [rxjava-scala README](https://github.com/Netflix/RxJava/tree/master/language-adaptors/rxjava-scala) for more information.
+
+* [Pull 503](https://github.com/Netflix/RxJava/pull/503) New Scala Bindings
+* [Pull 502](https://github.com/Netflix/RxJava/pull/502) Fix ObserveOn and add ParallelMerge Scheduler overload
+* [Pull 499](https://github.com/Netflix/RxJava/pull/499) ObserveOn Refactor
+* [Pull 492](https://github.com/Netflix/RxJava/pull/492) Implement the scheduler overloads for Range, From, StartWith
+* [Pull 496](https://github.com/Netflix/RxJava/pull/496) Add contravariant for min and max
+
+### Version 0.14.11 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.14.11%22)) ###
+
+* [Pull 486](https://github.com/Netflix/RxJava/pull/486) BugFix: AsyncSubject
+* [Pull 483](https://github.com/Netflix/RxJava/pull/483) Tweaks to DoOnEach and added DoOnError/DoOnCompleted
+
+This has a very slight breaking change by removing one `doOnEach` overload. The version was not bumped from 0.14 to 0.15 as it is so minor and the offending method was just released in the previous version.
+
+### Version 0.14.10 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.14.10%22)) ###
+
+* [Pull 481](https://github.com/Netflix/RxJava/pull/481) Operator: Using
+* [Pull 480](https://github.com/Netflix/RxJava/pull/480) BugFix: Emit an IllegalArgumentException instead of ArithmeticException if the observable is empty
+* [Pull 479](https://github.com/Netflix/RxJava/pull/479) Operator: DoOnEach
+* [Pull 478](https://github.com/Netflix/RxJava/pull/478) Operator: Min, MinBy, Max, MaxBy
+* [Pull 463](https://github.com/Netflix/RxJava/pull/463) Add Timeout Overloads
+
+### Version 0.14.9 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.14.9%22)) ###
+
+* [Pull 477](https://github.com/Netflix/RxJava/pull/477) BugFix: CompositeSubscription
+* [Pull 476](https://github.com/Netflix/RxJava/pull/476) BugFix: Don't emit null onComplete when no onNext received in AsyncSubject
+* [Pull 474](https://github.com/Netflix/RxJava/pull/474) BugFix: Reduce an empty observable
+* [Pull 474](https://github.com/Netflix/RxJava/pull/474) BugFix: non-deterministic unit test
+* [Pull 472](https://github.com/Netflix/RxJava/pull/472) BugFix: Issue 431 Unsubscribe with Schedulers.newThread
+* [Pull 470](https://github.com/Netflix/RxJava/pull/470) Operator: Last
+
+### Version 0.14.8 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.14.8%22)) ###
+
+* [Pull 460](https://github.com/Netflix/RxJava/pull/460) Operator: Amb
+* [Pull 466](https://github.com/Netflix/RxJava/pull/466) Refactor Unit Tests
+
+### Version 0.14.7 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.14.7%22)) ###
+
+* [Pull 459](https://github.com/Netflix/RxJava/pull/459) Fix multiple unsubscribe behavior
+* [Pull 458](https://github.com/Netflix/RxJava/pull/458) rxjava-android: OperationObserveFromAndroidComponent
+* [Pull 453](https://github.com/Netflix/RxJava/pull/453) Fix error handling in map operator
+* [Pull 450](https://github.com/Netflix/RxJava/pull/450) Operator: TimeInterval
+* [Pull 452](https://github.com/Netflix/RxJava/pull/451) Scheduler Overload of Just/Return Operator
+* [Pull 433](https://github.com/Netflix/RxJava/pull/433) Fixes: Next Operator
+* [Commit d64a8c5](https://github.com/Netflix/RxJava/commit/d64a8c5f73d8d1a5de1861e0d20f12609b408880) Update rxjava-apache-http to Apache HttpAsyncClient 4.0 GA 
+
+### Version 0.14.6 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.14.6%22)) ###
+
+* [Pull 441](https://github.com/Netflix/RxJava/pull/441) Fixed the issue that 'take' does not call 'onError'
+* [Pull 443](https://github.com/Netflix/RxJava/pull/443) OperationSwitch notify onComplete() too early.
+* [Pull 434](https://github.com/Netflix/RxJava/pull/434) Timeout operator and SerialSubscription
+* [Pull 447](https://github.com/Netflix/RxJava/pull/447) Caching the result of 'isInternalImplementation'
+
+### Version 0.14.5 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.14.5%22)) ###
+
+* [Pull 438](https://github.com/Netflix/RxJava/pull/438) Kotlin Language Adaptor
+
+### Version 0.14.4 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.14.4%22)) ###
+
+* [Issue 428](https://github.com/Netflix/RxJava/issues/428) Fix: buffer() using TimeAndSizeBasedChunks incorrectly forces thread into interrupted state
+* [Pull 435](https://github.com/Netflix/RxJava/pull/435) rx-apache-http recognizes "Transfer-Encoding: chunked" as an HTTP stream
+* [Pull 437](https://github.com/Netflix/RxJava/pull/437) Fixes: Scheduler and Merge
+
+
+### Version 0.14.3 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.14.3%22)) ###
+
+* [Pull 407](https://github.com/Netflix/RxJava/pull/407) Operator: RefCount
+* [Pull 410](https://github.com/Netflix/RxJava/pull/410) Operator: Contains
+* [Pull 411](https://github.com/Netflix/RxJava/pull/411) Unit Test fix: update counter before triggering latch 
+* [Pull 413](https://github.com/Netflix/RxJava/pull/413) Fixed the issues of takeLast(items, 0) and null values
+* [Pull 414](https://github.com/Netflix/RxJava/pull/414) Operator: SkipLast
+* [Pull 415](https://github.com/Netflix/RxJava/pull/415) Operator: Empty with scheduler
+* [Pull 416](https://github.com/Netflix/RxJava/pull/416) Operator: Throw with scheduler 
+* [Pull 420](https://github.com/Netflix/RxJava/pull/420) Scala Adaptor Improvements
+* [Pull 422](https://github.com/Netflix/RxJava/pull/422) JRuby function wrapping support
+* [Pull 424](https://github.com/Netflix/RxJava/pull/424) Operator: IgnoreElements
+* [Pull 426](https://github.com/Netflix/RxJava/pull/426) PublishSubject ReSubscribe for publish().refCount() Behavior
+
+### Version 0.14.2 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.14.2%22)) ###
+
+* [Pull 403](https://github.com/Netflix/RxJava/pull/403) Operators: Cast and OfType
+* [Pull 401](https://github.com/Netflix/RxJava/pull/401) Operator: DefaultIfEmpty
+* [Pull 409](https://github.com/Netflix/RxJava/pull/409) Operator: Synchronize with object
+
+### Version 0.14.1 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.14.1%22)) ###
+
+* [Pull 402](https://github.com/Netflix/RxJava/pull/402) rxjava-apache-http improvements
+
+### Version 0.14.0 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.14.0%22)) ###
+
+Further progress to the Scala adaptor and a handful of new operators.
+
+Bump to 0.14.0 due to small breaking change to `distinct` operator removing overloaded methods with `Comparator`. These methods were added in 0.13.2 and determined to be incorrect.
+
+This release also includes a new contrib module, [rxjava-apache-http](https://github.com/Netflix/RxJava/tree/master/rxjava-contrib/rxjava-apache-http) that provides an Observable API to the Apache HttpAsyncClient.
+
+* [Pull 396](https://github.com/Netflix/RxJava/pull/396) Add missing methods to Scala Adaptor
+* [Pull 390](https://github.com/Netflix/RxJava/pull/390) Operators: ElementAt and ElementAtOrDefault
+* [Pull 398](https://github.com/Netflix/RxJava/pull/398) Operators: IsEmpty and Exists (instead of Any)
+* [Pull 397](https://github.com/Netflix/RxJava/pull/397) Observable API for Apache HttpAsyncClient 4.0
+* [Pull 400](https://github.com/Netflix/RxJava/pull/400) Removing `comparator` overloads of `distinct`
+
+### Version 0.13.5
+
+* Upload to Sonatype failed so version skipped
+
+### Version 0.13.4 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.13.4%22)) ###
+
+* [Pull 393](https://github.com/Netflix/RxJava/pull/393) Parallel Operator & ObserveOn/ScheduledObserver Fixes
+* [Pull 394](https://github.com/Netflix/RxJava/pull/394) Change Interval and Sample default Scheduler
+* [Pull 391](https://github.com/Netflix/RxJava/pull/391) Fix OSGI support for rxjava-scala
+
+### Version 0.13.3
+
+* Upload to Sonatype failed so version skipped
+
+### Version 0.13.2 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.13.2%22)) ###
+
+* [Pull 389](https://github.com/Netflix/RxJava/pull/389) Scala Adaptor Improvements
+* [Pull 382](https://github.com/Netflix/RxJava/pull/382) Removing deprecated RxImplicits from rxjava-scala
+* [Pull 381](https://github.com/Netflix/RxJava/pull/381) Operator: mapWithIndex
+* [Pull 380](https://github.com/Netflix/RxJava/pull/380) Implemented `distinct` and `distinctUntilChanged` variants using a comparator
+* [Pull 379](https://github.com/Netflix/RxJava/pull/379) Make `interval` work with multiple subscribers
+
 ### Version 0.13.1 ([Maven Central](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20v%3A%220.13.1%22)) ###
 
 This release includes a new Scala adaptor as part of the effort from issue https://github.com/Netflix/RxJava/issues/336 pursuing idiomatic Scala support.

gradle.properties

@@ -1 +1 @@
-version=0.13.2-SNAPSHOT
+version=0.15.2-SNAPSHOT

language-adaptors/rxjava-groovy/src/test/groovy/rx/lang/groovy/ObservableTests.groovy

@@ -345,6 +345,143 @@ def class ObservableTests {
           assertEquals(6, count);
     }
 
+    @Test
+    public void testToMap1() {
+        Map actual = new HashMap();
+
+        Observable.from("a", "bb", "ccc", "dddd")
+        .toMap({String s -> s.length()})
+        .toBlockingObservable()
+        .forEach({s -> actual.putAll(s); });
+
+        Map expected = new HashMap();
+        expected.put(1, "a");
+        expected.put(2, "bb");
+        expected.put(3, "ccc");
+        expected.put(4, "dddd");
+
+        assertEquals(expected, actual);
+    }
+
+    @Test
+    public void testToMap2() {
+        Map actual = new HashMap();
+
+        Observable.from("a", "bb", "ccc", "dddd")
+        .toMap({String s -> s.length()}, {String s -> s + s})
+        .toBlockingObservable()
+        .forEach({s -> actual.putAll(s); });
+
+        Map expected = new HashMap();
+        expected.put(1, "aa");
+        expected.put(2, "bbbb");
+        expected.put(3, "cccccc");
+        expected.put(4, "dddddddd");
+
+        assertEquals(expected, actual);
+    }
+
+    @Test
+    public void testToMap3() {
+        Map actual = new HashMap();
+
+        LinkedHashMap last3 = new LinkedHashMap() {
+            public boolean removeEldestEntry(Map.Entry e) {
+                return size() > 3;
+            }
+        };
+
+        Observable.from("a", "bb", "ccc", "dddd")
+        .toMap({String s -> s.length()}, {String s -> s + s}, { last3 })
+        .toBlockingObservable()
+        .forEach({s -> actual.putAll(s); });
+
+        Map expected = new HashMap();
+        expected.put(2, "bbbb");
+        expected.put(3, "cccccc");
+        expected.put(4, "dddddddd");
+
+        assertEquals(expected, actual);
+    }
+    @Test
+    public void testToMultimap1() {
+        Map actual = new HashMap();
+
+        Observable.from("a", "b", "cc", "dd")
+        .toMultimap({String s -> s.length()})
+        .toBlockingObservable()
+        .forEach({s -> actual.putAll(s); });
+
+        Map expected = new HashMap();
+
+        expected.put(1, Arrays.asList("a", "b"));
+        expected.put(2, Arrays.asList("cc", "dd"));
+
+        assertEquals(expected, actual);
+    }
+
+    @Test
+    public void testToMultimap2() {
+        Map actual = new HashMap();
+
+        Observable.from("a", "b", "cc", "dd")
+        .toMultimap({String s -> s.length()}, {String s -> s + s})
+        .toBlockingObservable()
+        .forEach({s -> actual.putAll(s); });
+
+        Map expected = new HashMap();
+
+        expected.put(1, Arrays.asList("aa", "bb"));
+        expected.put(2, Arrays.asList("cccc", "dddd"));
+
+        assertEquals(expected, actual);
+    }
+
+    @Test
+    public void testToMultimap3() {
+        Map actual = new HashMap();
+
+        LinkedHashMap last1 = new LinkedHashMap() {
+            public boolean removeEldestEntry(Map.Entry e) {
+                return size() > 1;
+            }
+        };
+
+        Observable.from("a", "b", "cc", "dd")
+        .toMultimap({String s -> s.length()}, {String s -> s + s}, { last1 })
+        .toBlockingObservable()
+        .forEach({s -> actual.putAll(s); });
+
+        Map expected = new HashMap();
+
+        expected.put(2, Arrays.asList("cccc", "dddd"));
+
+        assertEquals(expected, actual);
+    }
+
+    @Test
+    public void testToMultimap4() {
+        Map actual = new HashMap();
+
+        LinkedHashMap last1 = new LinkedHashMap() {
+            public boolean removeEldestEntry(Map.Entry e) {
+                return size() > 2;
+            }
+        };
+
+        Observable.from("a", "b", "cc", "dd", "eee", "eee")
+        .toMultimap({String s -> s.length()}, {String s -> s + s}, { last1 }, 
+            {i -> i == 2 ? new ArrayList() : new HashSet() })
+        .toBlockingObservable()
+        .forEach({s -> actual.putAll(s); });
+
+        Map expected = new HashMap();
+
+        expected.put(2, Arrays.asList("cccc", "dddd"));
+        expected.put(3, new HashSet(Arrays.asList("eeeeee")));
+
+        assertEquals(expected, actual);
+    }
 
     def class AsyncObservable implements OnSubscribeFunc {
 

language-adaptors/rxjava-groovy/src/test/groovy/rx/lang/groovy/TestParallel.groovy

@@ -0,0 +1,36 @@
+/**
+ * Copyright 2013 Netflix, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package rx.lang.groovy
+
+import org.junit.Test
+
+import rx.Observable
+import rx.Scheduler
+import rx.concurrency.Schedulers
+import rx.util.functions.Func1
+
+class TestParallel {
+
+    @Test
+    public void testParallelOperator() {
+        Observable.range(0, 100)
+                .parallel({
+                    it.map({ return it; })
+                })
+                .toBlockingObservable()
+                .forEach({ println("T: " + it + " Thread: " + Thread.currentThread());  });
+    }
+}

language-adaptors/rxjava-jruby/README.md

@@ -0,0 +1,45 @@
+# JRuby Adaptor for RxJava
+
+This adaptor improves the success and performance of RxJava when Ruby `Proc` is passed to an RxJava method.
+
+This enables correct and efficient execution of code such as:
+
+```ruby
+  Observable.from("one", "two", "three").
+    take(2).
+    subscribe {|val| puts val}
+```
+
+# Usage
+
+Require the JAR file as usual. After requiring the JAR, you must also require the interop code:
+
+```ruby
+require "rx/lang/jruby/interop"
+```
+
+# Binaries
+
+Binaries and dependency information for Maven, Ivy, Gradle and others can be found at [http://search.maven.org](http://search.maven.org/#search%7Cga%7C1%7Ca%3A%22rxjava-jruby%22).
+
+Example for Maven:
+
+```xml
+<dependency>
+    <groupId>com.netflix.rxjava</groupId>
+    <artifactId>rxjava-jruby</artifactId>
+    <version>x.y.z</version>
+</dependency>
+```
+
+and for Ivy:
+
+```xml
+<dependency org="com.netflix.rxjava" name="rxjava-jruby" rev="x.y.z" />
+```
+
+and for Gradle:
+
+```groovy
+compile 'com.netflix.rxjava:rxjava-jruby:x.y.z'
+```