ensureEval for response streaming

finagle · Aug 22, 2017 · f7b62d3 · f7b62d3
1 parent e7e8976
commit f7b62d3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/iteratee/src/main/scala/io/finch/iteratee/package.scala b/iteratee/src/main/scala/io/finch/iteratee/package.scala
@@ -89,7 +89,7 @@ trait LowPriorityInstances extends FutureModule {
       response.setChunked(true)
       response.contentType = w.value
       val writer = response.writer
-      enum.map(e.apply(_, cs)).into(iteratee(writer)).ensure(writer.close())
+      enum.ensureEval(Eval.later(writer.close())).map(e.apply(_, cs)).into(iteratee(writer))
       response
     })
   }