diff options
| -rw-r--r-- | core/lib/Fiber.scala | 2 | ||||
| -rw-r--r-- | core/lib/FiberTypes.scala | 1 |
2 files changed, 1 insertions, 2 deletions
diff --git a/core/lib/Fiber.scala b/core/lib/Fiber.scala index bf55cf4..f4edffa 100644 --- a/core/lib/Fiber.scala +++ b/core/lib/Fiber.scala @@ -127,7 +127,7 @@ object Fiber extends FiberConversions with FiberTypes { * [[Fiber.emit]]ted by the fiber. */ def run[Out](thunk: ⇒ Unit @fiber[Out]): Observable[Out] = { - var state = new FiberState + val state = new FiberState monix.reactive.Observable.create[Out](OverflowStrategy.Unbounded) { out ⇒ val cancelable = MultiAssignmentCancelable() diff --git a/core/lib/FiberTypes.scala b/core/lib/FiberTypes.scala index 35f6a42..4f438d8 100644 --- a/core/lib/FiberTypes.scala +++ b/core/lib/FiberTypes.scala @@ -1,6 +1,5 @@ package eu.mulk.fibers -import scala.language.implicitConversions import scala.util.continuations.cpsParam private[fibers] trait FiberTypes { |