decouple reduce

breaking changes to accumulator and result selector function signature.
take and return by-value, reduce will move for you.

switch from abort to terminate

1 files changed, 1 insertions, 1 deletions

diff --git a/Rx/v2/src/rxcpp/schedulers/rx-newthread.hpp b/Rx/v2/src/rxcpp/schedulers/rx-newthread.hpp
index bed6ef9..c683996 100644
--- a/Rx/v2/src/rxcpp/schedulers/rx-newthread.hpp
+++ b/Rx/v2/src/rxcpp/schedulers/rx-newthread.hpp
@@ -82,7 +82,7 @@ private:
             state->lifetime.add([keepAlive](){
                 std::unique_lock<std::mutex> guard(keepAlive->lock);
                 auto expired = std::move(keepAlive->q);
-                if (!keepAlive->q.empty()) abort();
+                if (!keepAlive->q.empty()) std::terminate();
                 keepAlive->wake.notify_one();
             });