raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

=str Mark LazyFutureSource final.

Browse source 
Signed-off-by: He-Pin <hepin1989@gmail.com>
This commit is contained in:
He-Pin 2023-08-22 13:02:19 +08:00 • committed by kerr
parent 580f12c29f
commit fc26f57c09
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/LazyFutureSource.scala
View file

@ -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)