raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11
21028 commits 1 branch 31 tags 268 MiB
Commit graph

124 commits

Author SHA1 Message Date
Gilad Hoch
edee4ba409 +str #22711 adding GroupedWeightedWithin 2017-04-28 15:07:06 +02:00
Thomas Alton
626d07edca Schedule timer for remaining delayed elements #22416 2017-03-30 16:27:01 +02:00
Martynas Mickevičius
2a9c0370e0 Add @InternalApi annotations and private markers on internal apis (#22563) 
* #22506 Mark materializer extension as @InternalApi

* #22506 Added missing annotations on internal apis in the fusing package

* #22506 Missing annotations in io package

* #22506 Add internal api annotations in impl package

* #22563 more hiding of the classes in the impl package

* #22563 Formatting fixes

* #22506 Fix private access in stream tcl tests
 2017-03-16 20:04:07 +01:00
Sergey
ba213b7fee GroupedWithin cold emit fix (#22407) 
* groupedWithin cold emit fix

* lowered numbers in tests; removed meaningless assertions
 2017-03-14 13:45:45 +01:00
Hawstein
873e87fb33 =str refine built-in Take and TakeWhile stages (#21871) 
* refine build-in stages:

* change InHandler to avoid unnecessary condition check
* remove unnecessary local variable
* fix typo

* revert the drop stage change and remove timer
 2017-02-14 12:24:28 +01:00
Philippus Baalman
6c7085252a extended copyright into 2017 2017-01-04 17:37:15 +01:00
Konrad Malawski
e7e1f74427 =str more specific error type if idle-timeout triggers in tcp 2016-12-14 12:39:24 +01:00
Hawstein
c373cef20f use SimpleLinearGraphStage to reduce the boilerplate code #21830 2016-11-18 10:13:15 +01:00
Hawstein
96a1d2a081 rewrite Buffer as a GraphStage #21528 2016-11-15 18:48:33 +01:00
Andy Chung
fff707781e Took grab and pull out of try 2016-11-04 16:13:11 +00:00
Andy Chung
a6a4d1ac7f Fixed error handling behaviour of Fold and Reduce 2016-11-04 10:38:35 +00:00
Falmarri
a28d2c579f Added a flag on takeWhile to allow it to include the final element, #21330 2016-10-18 12:02:59 +02:00
Mateus Dubiela Oliveira
c3abde60d5 Add scanAsync to Akka Streams, similar to scan but taking a Future (#21553) 
* Add comprehensive tests
* Add documentation

* Damn comma after rebase

* Add documentation for foldAsync and scanAsync

* Rename aggreator and aggreating to current

* Remove out availability check

* Revert removing out and some refactors

* Formatting documentation

* Use after instead of Promise in test

* Use package reference to after and some refactoring
 2016-10-17 16:43:11 +02:00
Vsevolod Belousov
0e60020c58 fold async emits zero given an empty stream #21562 2016-10-17 09:02:54 +02:00
Patrik Nordwall
79d8ec87fc Delay should not pull when buffer is full with Backpressure strategy, #21334 
Additionally
* nano time conversion and calculation fix
* refactoring of Delay.onPush
 2016-09-13 16:10:49 +02:00
Michał Płachta
b3bba1229f Make map stage final and refactor OneBoundedSetup to take a decider. (#21374) 
* Remove new from Map constructions
 2016-09-08 11:47:17 +02:00
Patrik Nordwall
a95b2d6746 fail fast in mapAsync for completed failed future, #21318 (#21322) 
* fail fast in mapAsync for completed failed future, #21318

* the callback was not run until todo == parallelism or the sync
  event limit was reached, and that can be a problem if upstream
  stages are slow (noticed this for a blocking Kafka producer stage)

* skip callback for completed futures

* fix callback allocation
 2016-08-30 19:30:08 +02:00
drewhk
f062687a0e Merge pull request #21259 from drewhk/wip-20933-recoverWith-nondetached-drewhk 
#20933: Make RecoverWith non-detached (also eliminates race in test)
 2016-08-30 10:38:00 +02:00
Cédric Chantepie
324a40ba97 =str Refactoring to avoid distinct handler instantiation for stage logics (#21309) 
* Refactoring to avoid distinct handler instantiation for stage logics

* setHandlers
 2016-08-29 13:00:48 +01:00
Cédric Chantepie
efc87af58a FoldAsync op for Flow #18603 2016-08-24 21:02:32 +02:00
Endre Sándor Varga
32455d3990 #20933: Make RecoverWith non-detached (also eliminates race in test) 2016-08-23 13:13:11 +02:00
Kam Kasravi
438f489060 fixes #21193 Expose a number of GraphStage attributes 2016-08-18 10:01:43 -07:00
Endre Sándor Varga
a6cf6c646e Optimize Fold supervision 2016-08-01 11:31:12 +02:00
Endre Sándor Varga
5382014133 make Map a GraphStage 2016-08-01 11:31:07 +02:00
zhxiaog
9683e4bc58 migrate Fold, Sliding, Grouped to GraphStage (#20914) 2016-07-08 14:24:03 +02:00
Konrad Malawski
19f6c0c61c Merge pull request #20919 from ktoso/agolubev-20843-Scan.in-cannot-pull-closed-port-agolubev 
Agolubev 20843 scan.in cannot pull closed port agolubev
 2016-07-08 14:09:15 +02:00
Konrad Malawski
a299644b21 =str 20843 Scan failure should flow downstream ASAP 2016-07-08 14:08:27 +02:00
Alexander Golubev
f679e14168 =str 20843 Scan.in cannot pull closed port 2016-07-08 10:42:16 +02:00
Kam Kasravi
1d692daaad Fixes #20543 GraphStage subtypes should not be private to akka 2016-07-05 17:12:35 -07:00
Michał Płachta
00c5f49c7a Replace PushStage-based Log with GraphStage (part of #19834) (#20788) 
* Replace PushStage-based Log with GraphStage (part of #19834)

* Remove LogLogic and FilterLogic toStrings
 2016-06-22 16:36:18 +02:00
Kam Kasravi
049b95077f fixes #20414 Allow different ActorMaterializer subtypes 2016-06-07 07:13:03 -07:00
Björn Antonsson
c66ce62d63 Update to a working version of Scalariform 2016-06-02 22:12:36 +02:00
Endre Sándor Varga
14b70836a7 #20573 Fixing wrong initial buffer sizes in delay, and one logic bug 2016-05-24 11:42:17 +02:00
Samuel Tardieu
e0c64f59d8 =str #20550 only accept -1 for infinite retries in recoverWithRetries (#20555) 2016-05-19 11:45:31 +02:00
2beaucoup
e5c0872603 =str remove unused akka.stream.impl.fusing.Completed (#20468) 2016-05-06 23:58:01 +02:00
2beaucoup
bc7cd17bee =htc Various minor cleanups (#20451) 
* minor fixes

* remove now superfluous buffer from MultipartUnmarshaller

* remove unused TokenSourceActor

* remove FIXME: add tests, see #16437

* removed unused param remoteAddress (comment: TODO: remove after #16168 is cleared)

* convert FIXME to TODO (#18709)

* reenable tests in {Request|Response}RendererSpec due to fixed #15981

* remove logging workaround in StreamTestDefaultMailbox due to fixed #15947
 2016-05-06 10:32:06 +02:00
Priyanka Chordia
1f8225087f Convert Completed from PushPullStage to GraphStage (#20454) 2016-05-05 11:49:02 +02:00
David Knapp
c72890b113 Str #20217 If the future in mapAsync is already available, don't dispatch it (#20375) 2016-04-28 22:23:03 +02:00
Konrad Malawski
0e11ec2057 !htc #20371 allows for simple HTTPS usage from Java, fixes typo in APIs (#20373) 2016-04-25 12:01:03 +02:00
Patrik Nordwall
dfbcd948bf Merge pull request #20325 from akka/wip-convert-scan-to-graphstage-√ 
Converts the Scan-operation from PushPullStage to GraphStage
 2016-04-20 15:37:16 +02:00
David Knapp
d7fe98e1c4 #20123 Added recoverWithRetries which adds a parameter to limit the (#20137) 
number of attempts. Existing recoverWith method behavior remains unchanged.
 2016-04-20 15:24:12 +02:00
zhxiaog
7207189d6a convert Recover to GraphStage 2016-04-18 15:23:05 +08:00
Viktor Klang
455805cda9 Converts the Scan-operation from PushPullStage to GraphStage 2016-04-15 10:51:24 +02:00
Michał Płachta
8376fa8cfd Replace PushStage-based Filter with GraphStage (part of #19834) (#20269) 2016-04-14 11:04:08 +02:00
Konrad Malawski
b9ab232cac str #20262 reduce should fail explicitly on empty stream (#20267) 
* str #20262 reduce should fail explicitly on empty stream

* str #20262 document reduce behaviour on empty stream
 2016-04-11 15:36:10 +02:00
Endre Sándor Varga
60c8648b59 20232: Fix missing last group in groupedWithin 2016-04-05 15:01:18 +02:00
Viktor Klang (√)
598799d5ae =str - Improves performance of mapAsync 
* Removes allocations

* Removes indirections & shortens code paths
 2016-04-04 13:11:22 +02:00
Evgeny Vanslov
f42ab58b05 Replaced PushStage based TakeWhile with GraphStage #19834 2016-04-01 11:34:30 +03:00
Alexander Golubev
69e6052cbe +str #18620 add Source.blocking() for legacy API integration 2016-03-31 10:29:48 -04:00
Alexander Golubev
951afec88e =str 19834 Migrating PushStages to GraphStage 
Collect, DropWhile, LimitWeighted
 2016-03-22 10:44:27 -04:00