fix reactive-streams#96

Updates CONTRIBUTING.md with Gatekeeper SLAs

=tck method names and fine-details in some specs improved

=tck reactive-streams#128 TCK updated to reflect merged rules 2.13 and 2.14

Moves the examples out to its own sub-project and makes sure that they are compiled but not published.

=tck reactive-streams#138 clarify docs on registerOnSubscribe

Aims to clarify confusion about this method, as seen in reactive-streams#138

fix reactive-streams#96

fix reactive-streams#95 gradle build tool

makes gradlew executable

 add inter dependency

add ivy publish incubator plugin  but using this url "${rootProject.buildDir}/repo"

 merge

add example project

Author: ouertani

.gitignore

@@ -13,3 +13,15 @@ target/
 .history
 .idea
 .idea_modules
+.gradle
+.settings
+bin
+build
+out
+*.iml
+*.ipr
+*.iws
+test-output
+test-results
+test-tmp
+*.class

CONTRIBUTING.md

@@ -17,7 +17,14 @@ To ensure consistent development of Reactive Streams towards their goal, a group
 * Twitter Inc., currently represented by Marius Eriksen (@mariusaeriksen)
 * Typesafe Inc., currently represented by Viktor Klang (@viktorklang) and Roland Kuhn (@rkuhn)
 
-The role of this group is detailed in the following, additions to this list are made by pull request as defined below, removals require the consent of the entity to be removed or unanimous consent of all other gatekeepers. Changing a representative of one of the gatekeeper entities can be done by a member of that entity without requiring consent from the other gatekeepers.
+The role of this group is detailed in the following, additions to this list are made by pull request as defined below, removals require the consent of the entity to be removed or unanimous consent of all other Gatekeepers. Changing a representative of one of the gatekeeper entities can be done by a member of that entity without requiring consent from the other Gatekeepers.
+
+Gatekeepers commit to the following:
+
+1. 1-week SLA on :+1: or :-1: Pull Requests
+   * If a Gatekeeper will be unavailabile for a period of time, notify @reactive-streams/contributors and appoint who will vote in his/her place in the mean time
+2. tag @reactive-streams/contributors with a deadline when there needs to be a vote on an Issue,
+    with at least 1 week of notice (see rule 1 above)
 
 ## General Workflow
 

CopyrightWaivers.txt

@@ -24,3 +24,4 @@ viktorklang    | Viktor Klang, [email protected], Typesafe Inc.
 smaldini       | Stephane Maldini, [email protected], Pivotal Software Inc.
 savulchik      | Stanislav Savulchik, [email protected]
 ktoso          | Konrad Malawski, [email protected], Typesafe Inc.
+ouertani       | Slim Ouertani, [email protected] 

api/build.gradle

@@ -0,0 +1 @@
+description = 'reactive-streams-api'

api/build.sbt

@@ -3,6 +3,9 @@
 /**
  * A Processor represents a processing stage—which is both a {@link Subscriber}
  * and a {@link Publisher} and obeys the contracts of both.
+ *
+ * @param <T> the type of element signaled to the {@link Subscriber}
+ * @param <R> the type of element signaled by the {@link Publisher}
  */
 public interface Processor<T, R> extends Subscriber<T>, Publisher<R> {
 }

api/src/main/java/org/reactivestreams/Processor.java

@@ -1,5 +1,14 @@
 package org.reactivestreams;
 
+/**
+ * A {@link Publisher} is a provider of a potentially unbounded number of sequenced elements, publishing them according to
+ * the demand received from its {@link Subscriber}(s).
+ * <p>
+ * A {@link Publisher} can serve multiple {@link Subscriber}s subscribed {@link #subscribe(Subscriber)}dynamically
+ * at various points in time.
+ *
+ * @param <T> the type of element signaled.
+ */
 public interface Publisher<T> {
 
     /**
@@ -11,9 +20,9 @@ public interface Publisher<T> {
      * <p>
      * A {@link Subscriber} should only subscribe once to a single {@link Publisher}.
      * <p>
-     * If the {@link Publisher} rejects the subscription attempt or otherwise fails it will 
+     * If the {@link Publisher} rejects the subscription attempt or otherwise fails it will
      * signal the error via {@link Subscriber#onError}.
-     * 
+     *
      * @param s the {@link Subscriber} that will consume signals from this {@link Publisher}
      */
     public void subscribe(Subscriber<? super T> s);

api/src/main/java/org/reactivestreams/Publisher.java

@@ -13,7 +13,7 @@
  * <p>
  * Demand can be signaled via {@link Subscription#request(long)} whenever the {@link Subscriber} instance is capable of handling more.
  *
- * @param <T> the Type of element signaled.
+ * @param <T> the type of element signaled.
  */
 public interface Subscriber<T> {
     /**

api/src/main/java/org/reactivestreams/Subscriber.java

@@ -0,0 +1,104 @@
+allprojects {
+    apply plugin: 'java'
+    apply plugin: 'maven'
+    apply plugin: 'eclipse'
+    apply plugin: 'idea'
+    apply plugin: 'ivy-publish'
+    
+
+    group = 'org.reactivestreams'
+    version = '0.4.0'
+
+	 
+    gradle.projectsEvaluated {
+        tasks.withType(JavaCompile) {
+            options.compilerArgs << "-Xlint:unchecked" << "-Xlint:deprecation"
+            options.encoding = 'UTF-8'           
+        }
+        
+        tasks.withType(Javadoc) {
+            source = sourceSets.main.allJava          
+           
+            configure(options) {  
+                encoding 'UTF-8'
+                docEncoding 'UTF-8'
+                charSet 'UTF-8'
+                linkSource true 
+                noTimestamp true               
+            }
+        }
+    }
+
+    uploadArchives {
+      
+        repositories {
+         
+            mavenDeployer {
+
+                repository(url: "https://oss.sonatype.org/service/local/staging/deploy/maven2")
+
+                pom.project {
+                    name 'org.reactivestreams'
+                    packaging 'jar'
+                    url 'http://www.reactive-streams.org/'
+                    inceptionYear '2014'
+
+                    scm {
+                        url '[email protected]:reactive-streams/reactive-streams.git'
+                        connection 'scm:git:[email protected]:reactive-streams/reactive-streams.git'
+                    }
+
+                    licenses {
+                        license {
+                            name 'CC0'
+                            url 'http://creativecommons.org/publicdomain/zero/1.0/'
+                            distribution 'repo'
+                        }
+                    }
+
+                    developers {
+                        developer {
+                            id 'reactive-streams-sig'
+                            name 'Reactive Streams SIG'
+                            url 'http://www.reactive-streams.org/'
+                        }
+                    }
+                }
+            }
+         
+        }
+    }
+    repositories {
+        mavenLocal()
+        mavenCentral()
+    }
+    
+    publishing {
+        repositories {
+            ivy {
+                // change to point to your repo, e.g. http://my.org/repo
+                url "${rootProject.buildDir}/repo"
+            }
+        }
+        publications {
+            ivy(IvyPublication) {
+                from components.java
+                descriptor.withXml {
+                    asNode().info[0].appendNode('description', description)
+                }
+            }
+        }
+    }
+}
+
+subprojects {
+
+    sourceCompatibility = 1.6
+    targetCompatibility = 1.6
+
+    compileJava.options.encoding = 'UTF-8'
+
+    javadoc {        
+        options.encoding = 'UTF-8'
+    }    
+}

build.gradle

@@ -0,0 +1,4 @@
+description = 'reactive-streams-examples'
+dependencies {
+    compile project(':reactive-streams-api')
+}

build.sbt

@@ -1,6 +1,7 @@
 package org.reactivestreams.example.unicast;
 
 import java.util.concurrent.atomic.AtomicLong;
+import java.util.concurrent.atomic.AtomicInteger;
 
 import org.reactivestreams.Subscription;
 import org.reactivestreams.Subscriber;

examples/build.gradle

@@ -0,0 +1,6 @@
+#Tue Aug 19 09:12:00 AST 2014
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists
+distributionUrl=http\://services.gradle.org/distributions/gradle-1.10-all.zip