File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
akka-stream/src/main/scala/akka/stream/impl/fusing Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -150,7 +150,7 @@ private[akka] object FlattenConcat {
150150 def isClosed : Boolean
151151 }
152152
153- class InflightSingleSource [T ](elem : T ) extends InflightSource [T ] {
153+ final class InflightSingleSource [T ](elem : T ) extends InflightSource [T ] {
154154 private var _hasNext = true
155155 override def materialize (): Unit =
156156 new UnsupportedOperationException (" Do not need materialization for InflightSingleSource." )
@@ -165,7 +165,7 @@ private[akka] object FlattenConcat {
165165 override def isClosed : Boolean = ! hasNext
166166 }
167167
168- class InflightIterableSource [T ](elements : Iterable [T ]) extends InflightSource [T ] {
168+ final class InflightIterableSource [T ](elements : Iterable [T ]) extends InflightSource [T ] {
169169 private val iterator : Iterator [T ] = elements.iterator
170170 override def materialize (): Unit =
171171 new UnsupportedOperationException (" Do not need materialization for InflightSingleSource." )
@@ -176,7 +176,7 @@ private[akka] object FlattenConcat {
176176 override def isClosed : Boolean = ! hasNext
177177 }
178178
179- object InflightEmptySource extends InflightSource [Any ] {
179+ final object InflightEmptySource extends InflightSource [Any ] {
180180 override def materialize (): Unit =
181181 new UnsupportedOperationException (" Do not need materialization for InflightSingleSource." )
182182 override def hasNext : Boolean = false
You can’t perform that action at this time.
0 commit comments