diff options
| author | Matthias Andreas Benkard <code@mail.matthias.benkard.de> | 2018-01-10 22:00:02 +0100 |
|---|---|---|
| committer | Matthias Andreas Benkard <code@mail.matthias.benkard.de> | 2018-01-10 22:08:01 +0100 |
| commit | 30e0a8c249a2ff2fc451b33f1837b16d0fa9d419 (patch) | |
| tree | c5f04616d78959f056ac998c8dec7c1c8efadbbc /project | |
| parent | 7e034b1c19b2e0686a38e0562ed26ddb1fd912d0 (diff) | |
React to monix.execution.Ack.Stop signals properly.
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.
Diffstat (limited to 'project')
0 files changed, 0 insertions, 0 deletions