aboutsummaryrefslogtreecommitdiff
path: root/core/lib
Commit message (Collapse)AuthorAgeFilesLines
* React to monix.execution.Ack.Stop signals properly.Matthias Andreas Benkard2018-01-101-6/+9
| | | | | | 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.
* Make fibers cancellable.Matthias Andreas Benkard2018-01-101-3/+9
| | | | | | | 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.
* Make Fiber.run stack-safe.Matthias Andreas Benkard2018-01-101-32/+39
| | | | | | 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.
* Add initial code and project files.Matthias Andreas Benkard2018-01-073-0/+250