From 2af13fb4904f85cb1935982157313b7b2d4d22aa Mon Sep 17 00:00:00 2001 From: Matthias Andreas Benkard Date: Sat, 29 Sep 2018 07:24:09 +0200 Subject: Fix some minor stylistic bugs. --- core/lib/Fiber.scala | 2 +- core/lib/FiberTypes.scala | 1 - 2 files changed, 1 insertion(+), 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 { -- cgit v1.2.3