| Commit message (Collapse) | Author | Age | Files | Lines |
|---|
| |
|
|
|
|
| |
Previously, we just ignored the return value of Observer.Sync.onNext
in the implementation of Fiber.run. Now we stop when we receive a
Stop response.
|
| |
|
|
|
|
|
| |
The Observable returned by Fiber.run now implements
monix.execution.Cancelable properly and will finish execution of a
fiber on the next shift point when its corresponding Observable is
cancelled.
|
| |
|
|
|
|
| |
Previously, Fiber.run was implemented with non-tail recursion, which
would blow the stack after too many effects were invoked. It is now a
stack-safe loop.
|
| |
|
