aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--core/lib/Fiber.scala2
-rw-r--r--core/lib/FiberTypes.scala1
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 {