Upgrade to 1.0.0.RC5.

Closes #143.

Author: ldaley

rxjava-reactive-streams/build.gradle

@@ -4,8 +4,8 @@ apply plugin: 'java'
 
 dependencies {
     compile 'io.reactivex:rxjava:1.0.+'
-    compile 'org.reactivestreams:reactive-streams:1.0.0.RC4'
-    testCompile 'org.reactivestreams:reactive-streams-tck:1.0.0.RC4'
+    compile 'org.reactivestreams:reactive-streams:1.0.0.RC5'
+    testCompile 'org.reactivestreams:reactive-streams-tck:1.0.0.RC5'
 }
 
 test {

rxjava-reactive-streams/src/test/java/rx/reactivestreams/TckPublisherTest.java renamed to rxjava-reactive-streams/src/test/java/rx/reactivestreams/TckAsynchronousPublisherTest.java

@@ -26,21 +26,15 @@
 import rx.schedulers.Schedulers;
 
 @Test
-public class TckPublisherTest extends PublisherVerification<Long> {
+public class TckAsynchronousPublisherTest extends PublisherVerification<Long> {
 
-    public static final long DEFAULT_TIMEOUT_MILLIS = 300L;
-    public static final long PUBLISHER_REFERENCE_CLEANUP_TIMEOUT_MILLIS = 1000L;
-
-    public TckPublisherTest() {
-        super(new TestEnvironment(DEFAULT_TIMEOUT_MILLIS), PUBLISHER_REFERENCE_CLEANUP_TIMEOUT_MILLIS);
+    public TckAsynchronousPublisherTest() {
+        super(new TestEnvironment(300L));
     }
 
     @Override
     public Publisher<Long> createPublisher(long elements) {
-        return RxReactiveStreams.toPublisher(
-            Observable.from(new CountdownIterable(elements))
-                .observeOn(Schedulers.computation())
-        );
+        return RxReactiveStreams.toPublisher(Observable.from(new CountdownIterable(elements)).observeOn(Schedulers.computation()));
     }
 
     @Override

rxjava-reactive-streams/src/test/java/rx/reactivestreams/TckSynchronousPublisherTest.java

@@ -0,0 +1,47 @@
+/**
+ * Copyright 2014 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.reactivestreams;
+
+import org.reactivestreams.Publisher;
+import org.reactivestreams.tck.PublisherVerification;
+import org.reactivestreams.tck.TestEnvironment;
+import org.testng.annotations.Test;
+import rx.Observable;
+import rx.RxReactiveStreams;
+import rx.reactivestreams.test.CountdownIterable;
+
+@Test
+public class TckSynchronousPublisherTest extends PublisherVerification<Long> {
+
+    public TckSynchronousPublisherTest() {
+        super(new TestEnvironment(300L));
+    }
+
+    @Override
+    public Publisher<Long> createPublisher(long elements) {
+        return RxReactiveStreams.toPublisher(Observable.from(new CountdownIterable(elements)));
+    }
+
+    @Override
+    public Publisher<Long> createFailedPublisher() {
+        // Null because we always successfully subscribe.
+        // If the observable is in error state, it will subscribe and then emit the error as the first item
+        // This is not an “error state” publisher as defined by RS
+        return null;
+    }
+
+}