Merge pull request #243 from reactive-streams/wip-234-cnp-errors-√

Addresses a couple of typos in the examples for AsyncSubscriber and Sync...

Author: viktorklang

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

@@ -94,7 +94,7 @@ private final void handleOnSubscribe(final Subscription s) {
         s.request(1); // Our Subscriber is unbuffered and modest, it requests one element at a time
       } catch(final Throwable t) {
         // Subscription.request is not allowed to throw according to rule 3.16
-        (new IllegalStateException(s + " violated the Reactive Streams rule 3.16 by throwing an exception from cancel.", t)).printStackTrace(System.err);
+        (new IllegalStateException(s + " violated the Reactive Streams rule 3.16 by throwing an exception from request.", t)).printStackTrace(System.err);
       }
     }
   }
@@ -111,7 +111,7 @@ private final void handleOnNext(final T element) {
               subscription.request(1); // Our Subscriber is unbuffered and modest, it requests one element at a time
             } catch(final Throwable t) {
               // Subscription.request is not allowed to throw according to rule 3.16
-              (new IllegalStateException(subscription + " violated the Reactive Streams rule 3.16 by throwing an exception from cancel.", t)).printStackTrace(System.err);
+              (new IllegalStateException(subscription + " violated the Reactive Streams rule 3.16 by throwing an exception from request.", t)).printStackTrace(System.err);
             }
           } else {
             done(); // This is legal according to rule 2.6

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

@@ -35,7 +35,7 @@ public abstract class SyncSubscriber<T> implements Subscriber<T> {
         s.request(1); // Our Subscriber is unbuffered and modest, it requests one element at a time
       } catch(final Throwable t) {
         // Subscription.request is not allowed to throw according to rule 3.16
-        (new IllegalStateException(s + " violated the Reactive Streams rule 3.16 by throwing an exception from cancel.", t)).printStackTrace(System.err);
+        (new IllegalStateException(s + " violated the Reactive Streams rule 3.16 by throwing an exception from request.", t)).printStackTrace(System.err);
       }
     }
   }
@@ -54,7 +54,7 @@ public abstract class SyncSubscriber<T> implements Subscriber<T> {
               subscription.request(1); // Our Subscriber is unbuffered and modest, it requests one element at a time
             } catch (final Throwable t) {
               // Subscription.request is not allowed to throw according to rule 3.16
-              (new IllegalStateException(subscription + " violated the Reactive Streams rule 3.16 by throwing an exception from cancel.", t)).printStackTrace(System.err);
+              (new IllegalStateException(subscription + " violated the Reactive Streams rule 3.16 by throwing an exception from request.", t)).printStackTrace(System.err);
             }
           } else {
             done();