From fc26f57c096e60559d413e08c150dfe9a2320fbf Mon Sep 17 00:00:00 2001 From: He-Pin Date: Tue, 22 Aug 2023 13:02:19 +0800 Subject: [PATCH] =str Mark LazyFutureSource final. Signed-off-by: He-Pin --- .../org/apache/pekko/stream/impl/fusing/LazyFutureSource.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/LazyFutureSource.scala b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/LazyFutureSource.scala index a56d2053f8..4e7f8df07e 100644 --- a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/LazyFutureSource.scala +++ b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/LazyFutureSource.scala @@ -32,7 +32,7 @@ import pekko.stream.stage.GraphStage import pekko.stream.stage.GraphStageLogic import pekko.stream.stage.OutHandler -private[pekko] class LazyFutureSource[T](f: () => Future[T]) extends GraphStage[SourceShape[T]] { +private[pekko] final class LazyFutureSource[T](f: () => Future[T]) extends GraphStage[SourceShape[T]] { require(f != null, "f should not be null.") private val out = Outlet[T]("LazyFutureSource.out") val shape: SourceShape[T] = SourceShape(out)