as_blocking().subscribe() now throws when on_error terminates the stream.
as_blocking().subscribe() now throws when on_error terminates the stream.

alexeymarkov/RxCpp,ReactiveX/RxCpp,alexeymarkov/RxCpp,alexeymarkov/RxCpp,Reactive-Extensions/RxCpp,ReactiveX/RxCpp,ReactiveX/RxCpp,Reactive-Extensions/RxCpp,Reactive-Extensions/RxCpp