+
+
+
+
+ To the extent possible under law,
+
+ Reactive Streams Special Interest Group
+ has waived all copyright and related or neighboring rights to
+ Reactive Streams JVM.
+ This work is published from:
+ United States.
+
- * A {@link Publisher} can serve multiple {@link Subscriber}s subscribed {@link #subscribe(Subscriber)}dynamically
+ * A {@link Publisher} can serve multiple {@link Subscriber}s subscribed {@link #subscribe(Subscriber)} dynamically
* at various points in time.
*
* @param
- * Data may still be sent to meet previously signalled demand after calling cancel as this request is asynchronous.
+ * Data may still be sent to meet previously signalled demand after calling cancel.
*/
public void cancel();
}
diff --git a/build.gradle b/build.gradle
index eecb748a..7f4708a1 100644
--- a/build.gradle
+++ b/build.gradle
@@ -3,7 +3,7 @@ subprojects {
apply plugin: "osgi"
group = "org.reactivestreams"
- version = "1.0.0.RC1"
+ version = "1.0.1"
sourceCompatibility = 1.6
targetCompatibility = 1.6
@@ -28,7 +28,7 @@ subprojects {
tasks.withType(Test) {
testLogging {
exceptionFormat "full"
- events "failed", "started"
+ events "failed", "started", "standard_out", "standard_error"
}
}
@@ -36,15 +36,21 @@ subprojects {
mavenCentral()
}
+
jar {
manifest {
- instruction "Bundle-Vendor", "Reactive Streams SIG"
- instruction "Bundle-Description", "Reactive Streams API"
- instruction "Bundle-DocURL", "http://reactive-streams.org"
+ instructionReplace "Bundle-Vendor", "Reactive Streams SIG"
+ instructionReplace "Bundle-Description", "Reactive Streams API"
+ instructionReplace "Bundle-DocURL", "http://reactive-streams.org"
+ instructionReplace "Bundle-Version", "1.0.1"
}
}
- if (name in ["reactive-streams", "reactive-streams-tck"]) {
+ if (name in ["reactive-streams",
+ "reactive-streams-tck",
+ "reactive-streams-tck-flow",
+ "reactive-streams-examples",
+ "reactive-streams-flow-bridge"]) {
apply plugin: "maven"
apply plugin: "signing"
diff --git a/examples/src/main/java/org/reactivestreams/example/unicast/AsyncIterablePublisher.java b/examples/src/main/java/org/reactivestreams/example/unicast/AsyncIterablePublisher.java
index 985144a8..2dee33da 100644
--- a/examples/src/main/java/org/reactivestreams/example/unicast/AsyncIterablePublisher.java
+++ b/examples/src/main/java/org/reactivestreams/example/unicast/AsyncIterablePublisher.java
@@ -1,3 +1,14 @@
+/************************************************************************
+* Licensed under Public Domain (CC0) *
+* *
+* To the extent possible under law, the person who associated CC0 with *
+* this code has waived all copyright and related or neighboring *
+* rights to this code. *
+* *
+* You should have received a copy of the CC0 legalcode along with this *
+* work. If not, see
+ * As with standard {@link Subscriber}s, an instance of this class
+ * should be subscribed to at most one (Reactive Streams or
+ * Flow) Publisher.
+ *