diff --git a/akka-stream/src/main/scala/akka/stream/impl/fusing/GraphStages.scala b/akka-stream/src/main/scala/akka/stream/impl/fusing/GraphStages.scala index 0b2931e125..e55a36d9a4 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/fusing/GraphStages.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/fusing/GraphStages.scala @@ -273,7 +273,7 @@ object GraphStages { setHandler(out, this) } - override def toString: String = s"SingleSource($elem)" + override def toString: String = "SingleSource" } final class FutureSource[T](val future: Future[T]) extends GraphStage[SourceShape[T]] { diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala b/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala index 2e4521a7f0..15a487a701 100644 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala @@ -724,7 +724,7 @@ final class Flow[-In, +Out, +Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends * * Delay precision is 10ms to avoid unnecessary timer scheduling cycles * - * Internal buffer has default capacity 16. You can set buffer size by calling `withAttributes(inputBuffer)` + * Internal buffer has default capacity 16. You can set buffer size by calling `addAttributes(inputBuffer)` * * '''Emits when''' there is a pending element in the buffer and configured time for this element elapsed * * EmitEarly - strategy do not wait to emit element if buffer is full diff --git a/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala b/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala index c7040766ab..7592a2d0f7 100644 --- a/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala +++ b/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala @@ -1000,7 +1000,7 @@ trait FlowOps[+Out, +Mat] { * * Delay precision is 10ms to avoid unnecessary timer scheduling cycles * - * Internal buffer has default capacity 16. You can set buffer size by calling `withAttributes(inputBuffer)` + * Internal buffer has default capacity 16. You can set buffer size by calling `addAttributes(inputBuffer)` * * '''Emits when''' there is a pending element in the buffer and configured time for this element elapsed * * EmitEarly - strategy do not wait to emit element if buffer is full diff --git a/akka-stream/src/main/scala/akka/stream/scaladsl/StreamConverters.scala b/akka-stream/src/main/scala/akka/stream/scaladsl/StreamConverters.scala index de5f39a9bf..5657ec5e7a 100644 --- a/akka-stream/src/main/scala/akka/stream/scaladsl/StreamConverters.scala +++ b/akka-stream/src/main/scala/akka/stream/scaladsl/StreamConverters.scala @@ -162,7 +162,8 @@ object StreamConverters { * configured through the ``akka.stream.blocking-io-dispatcher``. */ def asJavaStream[T](): Sink[T, java.util.stream.Stream[T]] = { - Sink.fromGraph(new QueueSink[T]()) + // TODO removing the QueueSink name, see issue #22523 + Sink.fromGraph(new QueueSink[T]().withAttributes(Attributes.none)) .mapMaterializedValue(queue ⇒ StreamSupport.stream( Spliterators.spliteratorUnknownSize(new java.util.Iterator[T] { var nextElementFuture: Future[Option[T]] = queue.pull()