From 15b95ab0e5c2a4535b2d7eb1277c5b930106adb6 Mon Sep 17 00:00:00 2001 From: Mathias Date: Thu, 23 Apr 2015 17:27:28 +0200 Subject: [PATCH] =str fix typo in internal type (`RejectAdditionalSubscribers`) --- .../src/main/scala/akka/stream/impl/CompletedPublishers.scala | 2 +- akka-stream/src/main/scala/akka/stream/impl/StreamLayout.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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 } }