Address comment

Author: injae-kim

stream-tests/src/test/java/org/apache/pekko/stream/javadsl/FlowTest.java

@@ -249,7 +249,6 @@ public void mustBeAbleToUseMapWithAutoCloseableResource() {
                     () -> (AutoCloseable) closed::incrementAndGet, (resource, elem) -> elem))
         .runWith(Sink.foreach(elem -> probe.getRef().tell(elem, ActorRef.noSender())), system);
 
-    Assert.assertEquals(closed.get(), 0);
     probe.expectMsgAllOf("1", "2", "3");
     Assert.assertEquals(closed.get(), 1);
   }

stream-tests/src/test/java/org/apache/pekko/stream/javadsl/SourceTest.java

@@ -824,7 +824,6 @@ public void mustBeAbleToUseMapWithAutoCloseableResource() {
         .mapWithResource(() -> (AutoCloseable) closed::incrementAndGet, (resource, elem) -> elem)
         .runWith(Sink.foreach(elem -> probe.getRef().tell(elem, ActorRef.noSender())), system);
 
-    Assert.assertEquals(closed.get(), 0);
     probe.expectMsgAllOf("1", "2", "3");
     Assert.assertEquals(closed.get(), 1);
   }

stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala

@@ -841,7 +841,7 @@ final class Flow[In, Out, Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends Gr
    *
    * Adheres to the [[ActorAttributes.SupervisionStrategy]] attribute.
    *
-   * You can configure the default dispatcher for this Source by changing the `akka.stream.materializer.blocking-io-dispatcher` or
+   * You can configure the default dispatcher for this Source by changing the `pekko.stream.materializer.blocking-io-dispatcher` or
    * set it for a given Source by using [[ActorAttributes]].
    *
    * '''Emits when''' the mapping function returns an element and downstream is ready to consume it

stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala

@@ -2554,7 +2554,7 @@ final class Source[Out, Mat](delegate: scaladsl.Source[Out, Mat]) extends Graph[
    *
    * Adheres to the [[ActorAttributes.SupervisionStrategy]] attribute.
    *
-   * You can configure the default dispatcher for this Source by changing the `akka.stream.materializer.blocking-io-dispatcher` or
+   * You can configure the default dispatcher for this Source by changing the `pekko.stream.materializer.blocking-io-dispatcher` or
    * set it for a given Source by using [[ActorAttributes]].
    *
    * '''Emits when''' the mapping function returns an element and downstream is ready to consume it

stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala

@@ -298,7 +298,7 @@ class SubFlow[In, Out, Mat](
    *
    * Adheres to the [[ActorAttributes.SupervisionStrategy]] attribute.
    *
-   * You can configure the default dispatcher for this Source by changing the `akka.stream.materializer.blocking-io-dispatcher` or
+   * You can configure the default dispatcher for this Source by changing the `pekko.stream.materializer.blocking-io-dispatcher` or
    * set it for a given Source by using [[ActorAttributes]].
    *
    * '''Emits when''' the mapping function returns an element and downstream is ready to consume it

stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala

@@ -289,7 +289,7 @@ class SubSource[Out, Mat](
    *
    * Adheres to the [[ActorAttributes.SupervisionStrategy]] attribute.
    *
-   * You can configure the default dispatcher for this Source by changing the `akka.stream.materializer.blocking-io-dispatcher` or
+   * You can configure the default dispatcher for this Source by changing the `pekko.stream.materializer.blocking-io-dispatcher` or
    * set it for a given Source by using [[ActorAttributes]].
    *
    * '''Emits when''' the mapping function returns an element and downstream is ready to consume it

stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala

@@ -1155,7 +1155,7 @@ trait FlowOps[+Out, +Mat] {
    *
    * Adheres to the [[ActorAttributes.SupervisionStrategy]] attribute.
    *
-   * You can configure the default dispatcher for this Source by changing the `akka.stream.materializer.blocking-io-dispatcher` or
+   * You can configure the default dispatcher for this Source by changing the `pekko.stream.materializer.blocking-io-dispatcher` or
    * set it for a given Source by using [[ActorAttributes]].
    *
    * '''Emits when''' the mapping function returns an element and downstream is ready to consume it