This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
The following commit(s) were added to refs/heads/main by this push:
new fc26f57c09 =str Mark LazyFutureSource final.
fc26f57c09 is described below
commit fc26f57c096e60559d413e08c150dfe9a2320fbf
Author: He-Pin <[email protected]>
AuthorDate: Tue Aug 22 13:02:19 2023 +0800
=str Mark LazyFutureSource final.
Signed-off-by: He-Pin <[email protected]>
---
.../scala/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)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
