From 88daf2e2dd6d1cd896fe846bcad96605cdf1f119 Mon Sep 17 00:00:00 2001 From: Johannes Rudolph Date: Wed, 15 Nov 2017 17:04:50 +0100 Subject: [PATCH] =str cosmetic changes to VirtualPublisher --- .../src/main/scala/akka/stream/impl/StreamLayout.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 33951f7f99..57bcb9e2c7 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/StreamLayout.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/StreamLayout.scala @@ -302,7 +302,7 @@ import scala.util.control.NonFatal * defers to the upstream that is connected during materialization. This would * be trivial if it were not for materialized value computations that may even * spawn the code that does `pub.subscribe(sub)` in a Future, running concurrently - * with the actual materialization. Therefore we implement a minimial shell here + * with the actual materialization. Therefore we implement a minimal shell here * that plugs the downstream and the upstream together as soon as both are known. * Using a VirtualProcessor would technically also work, but it would defeat the * purpose of subscription timeouts—the subscription would always already be @@ -352,7 +352,7 @@ import scala.util.control.NonFatal throw new IllegalStateException(s"internal error, unexpected state: $unexpected") } - override def toString: String = s"VirtualProcessor(state = ${get()})" + override def toString: String = s"VirtualPublisher(state = ${get()})" } /**