Skip to content

Commit 09cee95

Browse files
committed
Compile OK
1 parent bb533de commit 09cee95

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

tests/run-with-compiler-custom-args/staged-streams_1.scala

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -324,10 +324,7 @@ object Test {
324324
private def makeLinear[A: Type](stream: StagedStream[Expr[A]]): Producer[Expr[A]] = {
325325
stream match {
326326
case Linear(producer) => producer
327-
case nested: Nested[A, bt] => {
328-
val producer: Producer[bt] = nested.producer
329-
val nestedf: bt => StagedStream[A] = nested.nestedf
330-
327+
case Nested(producer, nestedf) => {
331328
/** Helper function that orchestrates the handling of the function that represents an `advance: Unit => Unit`.
332329
* It reifies a nested stream as calls to `advance`. Advance encodes the step function of each nested stream.
333330
* It is used in the init of a producer of a nested stream. When an inner stream finishes, the
@@ -385,7 +382,7 @@ object Test {
385382
val adv: Unit => Unit = { _ =>
386383
~hasNext.update(producer.hasNext(st))
387384
if(~hasNext.get) {
388-
// ~producer.step(st, (el: bt) => makeAdvanceFunction[Expr[A]](advf, (a => curr.update(a)), nestedf(el)))
385+
~producer.step(st, el => makeAdvanceFunction[Expr[A]](advf, (a => curr.update(a)), nestedf(el)))
389386
}
390387
}
391388

0 commit comments

Comments
 (0)