Merge pull request #187 from reactive-streams/wip-minor-fixes-√

Removes NumberIterablePublisher's type parameter and makes all the examp...

Author: viktorklang

examples/src/main/java/org/reactivestreams/example/unicast/AsyncIterablePublisher.java

@@ -14,10 +14,10 @@
  * AsyncIterablePublisher is an implementation of Reactive Streams `Publisher`
  * which executes asynchronously, using a provided `Executor` and produces elements
  * from a given `Iterable` in a "unicast" configuration to its `Subscribers`.
- 
+ *
  * NOTE: The code below uses a lot of try-catches to show the reader where exceptions can be expected, and where they are forbidden.
  */
-class AsyncIterablePublisher<T> implements Publisher<T> {
+public class AsyncIterablePublisher<T> implements Publisher<T> {
   private final static int DEFAULT_BATCHSIZE = 1024;
 
   private final Iterable<T> elements; // This is our data source / generator

examples/src/main/java/org/reactivestreams/example/unicast/InfiniteIncrementNumberPublisher.java

@@ -7,7 +7,7 @@
 import org.reactivestreams.Subscriber;
 import org.reactivestreams.Publisher;
 
-class InfiniteIncrementNumberPublisher extends AsyncIterablePublisher<Integer> {
+public class InfiniteIncrementNumberPublisher extends AsyncIterablePublisher<Integer> {
     public InfiniteIncrementNumberPublisher(final Executor executor) {
         super(new Iterable<Integer>() {
           @Override public Iterator<Integer> iterator() {

examples/src/main/java/org/reactivestreams/example/unicast/NumberIterablePublisher.java

@@ -7,7 +7,7 @@
 import org.reactivestreams.Subscriber;
 import org.reactivestreams.Publisher;
 
-class NumberIterablePublisher<T> extends AsyncIterablePublisher<Integer> {
+public class NumberIterablePublisher extends AsyncIterablePublisher<Integer> {
     public NumberIterablePublisher(final int from, final int to, final Executor executor) {
         super(new Iterable<Integer>() {
           { if(from > to) throw new IllegalArgumentException("from must be equal or greater than to!"); }