Commit graph

10 commits

Author SHA1 Message Date
Endre Sándor Varga
6b4a4848c9 =str #19067: Fixed error reporting after stage is closed. 2015-12-15 17:15:28 +01:00
Roland Kuhn
556012b7ee !str,htc replace and remove OneBoundedInterpreter
main work by @drewhk with contributions from @2m and @rkuhn

This work uncovered many well-hidden bugs in existing Stages, in
particular StatefulStage. These were hidden by the behavior of
OneBoundedInterpreter that normally behaves more orderly than it
guarantees in general, especially with respect to the timeliness of
delivery of upstream termination signals; the bugs were then that
internal state was not flushed when onComplete arrived “too early”.
2015-11-01 14:53:52 +01:00
Endre Sándor Varga
62a299f3a5 =str #18189: Explicitly disallow absorbTermination() from onDownstreamFinish() 2015-09-02 16:46:37 +02:00
Endre Sándor Varga
17733e5a54 +str #17418: Improved error handling for termination cases in Interpreter 2015-05-12 16:06:59 +02:00
Konrad Malawski
9607ec0cdf +str #17290 Adds preStart / postStop to AbstractStage
+ AsyncStage now uses preStart
+ Log stage now uses preStart (better perf), can be optimised more
2015-05-11 12:57:41 +02:00
Endre Sándor Varga
6ba5c0b4c6 =str #17351: Fix pushAndFinish improper stage termination 2015-05-05 11:57:17 +02:00
Patrik Nordwall
693dcbefcc +str #15750 Prototype of stream supervision
* add supervion for stages and built in ops run by interpreter
* add supervision for mapAsync and mapAsyncUnordered
* add supervision to groupBy and splitWhen
* reference doc for scala and java
2015-02-20 15:44:01 +01:00
Endre Sándor Varga
5202d59dda =str #16231: Protect jumpback table from corruption 2015-01-26 10:31:57 +01:00
Endre Sándor Varga
325e1b6915 =str: #16285: Expand should not drop elements on completion 2014-11-27 15:18:23 +01:00
Endre Sándor Varga
9ecd8b61fe +str: Implement efficient stream op DSL 2014-11-06 12:02:33 +01:00