diff --git a/akka-stream/src/main/scala/akka/stream/impl/CompletedPublishers.scala b/akka-stream/src/main/scala/akka/stream/impl/CompletedPublishers.scala
index b50545724e..fbd22a79d1 100644
--- a/akka-stream/src/main/scala/akka/stream/impl/CompletedPublishers.scala
+++ b/akka-stream/src/main/scala/akka/stream/impl/CompletedPublishers.scala
@@ -53,7 +53,7 @@ private[akka] case object CancelledSubscription extends Subscription {
 /**
  * INTERNAL API
  */
-private[akka] case object RejectAdditionalSubscibers extends Publisher[Nothing] {
+private[akka] case object RejectAdditionalSubscribers extends Publisher[Nothing] {
   import ReactiveStreamsCompliance._
   override def subscribe(subscriber: Subscriber[_ >: Nothing]): Unit =
     try {
diff --git a/akka-stream/src/main/scala/akka/stream/impl/StreamLayout.scala b/akka-stream/src/main/scala/akka/stream/impl/StreamLayout.scala
index d84232d5b8..f2160a4347 100644
--- a/akka-stream/src/main/scala/akka/stream/impl/StreamLayout.scala
+++ b/akka-stream/src/main/scala/akka/stream/impl/StreamLayout.scala
@@ -312,7 +312,7 @@ private[stream] class VirtualPublisher[T]() extends Publisher[T] {
     val sub = realPublisher.subscribe(s)
     // unreference the realPublisher to facilitate GC and
     // Sink.publisher is supposed to reject additional subscribers anyway
-    realPublisher = RejectAdditionalSubscibers[T]
+    realPublisher = RejectAdditionalSubscribers[T]
     sub
   }
 }