diff options
Diffstat (limited to 'core/lib/Fiber.scala')
-rw-r--r-- | core/lib/Fiber.scala | 2 |
1 files changed, 1 insertions, 1 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() |