path: root/core
Commit message (Collapse)AuthorAgeFilesLines
* Fix some minor stylistic bugs.Matthias Andreas Benkard2018-09-292-2/+1
* Add Bazel build files.Matthias Andreas Benkard2018-01-281-0/+8
* Add a cancellation test.Matthias Andreas Benkard2018-01-101-2/+41
* React to monix.execution.Ack.Stop signals properly.Matthias Andreas Benkard2018-01-102-7/+61
| | | | | | 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-074-0/+430