@@ -81,7 +81,7 @@ public void call(Subscriber<? super T> child) {
8181 */
8282 continue ;
8383 /*
84- * Note: although technically corrent , concurrent disconnects can cause
84+ * Note: although technically correct , concurrent disconnects can cause
8585 * unexpected behavior such as child subscribers never receiving anything
8686 * (unless connected again). An alternative approach, similar to
8787 * PublishSubject would be to immediately terminate such child
@@ -309,7 +309,7 @@ boolean add(InnerProducer<T> producer) {
309309 if (producers .compareAndSet (c , u )) {
310310 return true ;
311311 }
312- // if failed, some other operation succeded (another add, remove or termination)
312+ // if failed, some other operation succeeded (another add, remove or termination)
313313 // so retry
314314 }
315315 }
@@ -398,7 +398,7 @@ boolean checkTerminated(Object term, boolean empty) {
398398 ip .child .onCompleted ();
399399 }
400400 } finally {
401- // we explicitely unsubscribe/disconnect from the upstream
401+ // we explicitly unsubscribe/disconnect from the upstream
402402 // after we sent out the terminal event to child subscribers
403403 unsubscribe ();
404404 }
@@ -418,7 +418,7 @@ boolean checkTerminated(Object term, boolean empty) {
418418 ip .child .onError (t );
419419 }
420420 } finally {
421- // we explicitely unsubscribe/disconnect from the upstream
421+ // we explicitly unsubscribe/disconnect from the upstream
422422 // after we sent out the terminal event to child subscribers
423423 unsubscribe ();
424424 }
@@ -637,7 +637,7 @@ static final class InnerProducer<T> extends AtomicLong implements Producer, Subs
637637 /**
638638 * Indicates this child has not yet requested any value. We pretend we don't
639639 * see such child subscribers in dispatch() to allow other child subscribers who
640- * have requested to make progress. In a concurrent subscription scennario ,
640+ * have requested to make progress. In a concurrent subscription scenario ,
641641 * one can't be sure when a subscription happens exactly so this virtual shift
642642 * should not cause any problems.
643643 */
@@ -685,7 +685,7 @@ public void request(long n) {
685685 }
686686 // try setting the new request value
687687 if (compareAndSet (r , u )) {
688- // if successful, notify the parent dispacher this child can receive more
688+ // if successful, notify the parent dispatcher this child can receive more
689689 // elements
690690 parent .dispatch ();
691691 return ;
@@ -725,7 +725,7 @@ public long produced(long n) {
725725 }
726726 // try updating the request value
727727 if (compareAndSet (r , u )) {
728- // and return the udpated value
728+ // and return the updated value
729729 return u ;
730730 }
731731 // otherwise, some concurrent activity happened and we need to retry
0 commit comments