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

1071 commits

Author SHA1 Message Date
drewhk
c3c8a0bc73 Merge pull request #20141 from agolubev/19443-add-support-for-Java-Stream-agolubev 
19443 add support for java stream agolubev
 2016-05-03 11:59:59 +02:00
drewhk
d56ab090b7 Merge pull request #20295 from drewhk/wip-19978-specviolation-cleanup-drewhk 
#19978 SpecViolation should result in orderly shutdown of GraphInterp…
 2016-05-03 11:56:03 +02:00
Endre Sándor Varga
571cff340c #19978 SpecViolation should result in orderly shutdown of GraphInterpreter 2016-05-03 10:11:23 +02:00
Endre Sándor Varga
093d82ce00 +str #19443 add support or Java Stream 2016-04-29 23:31:56 -04: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
Andrea Peruffo
088bf1b842 =act Locale unaware method in Helpers. (#20412) 2016-04-28 15:32:46 +02:00
Patrik Nordwall
0b0a456e28 Merge pull request #20125 from kelebra/19039-kelebra-cycle 
#19039: Added cycle method to Source class.
 2016-04-26 16:47:02 +02:00
Oleksii Tkachuk
78e0a534f4 Fixed 19039 for both scaladsl and javadsl 
19039: Added cycle method to Source class for both scaladsl and javadsl. Test added.
 2016-04-26 07:37:03 -05: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
Michał Kiędyś
b983f19c1f Add basic support for Java 7 NIO file systems (#20293) 2016-04-25 11:25:26 +02:00
Rodolphe BELOUIN
936c97051a +str #19782 Transpose a sources sequence (#19795) 2016-04-22 12:04:28 +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
Patrik Nordwall
25eaa25318 Merge pull request #20335 from samueltardieu/success-ambiguity 
Clarify explanation of Source.actorRef termination in embedded doc
 2016-04-20 15:32:45 +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
Daniel Moran
c8352c04c4 Migrate BodyPartParser to GraphStage #20288. 2016-04-19 19:04:31 -07:00
Samuel Tardieu
34d51dcd00 Clarify explanation of Source.actorRef termination in embedded doc 
Make it clear that a Success instance (whose payload will be ignored)
must be sent to complete the source, and not the Success companion
object itself.

Use "a" before instances, and remove "a" before PoisonPill object.

The Java documentation has been aligned to the Scala documentation.
 2016-04-19 13:13:23 +02:00
Patrik Nordwall
c1f20cb520 Merge pull request #20351 from zhxiaogg/feature/zhxiaogg_Recover 
#20288 convert Recover to GraphStage
 2016-04-19 10:56:12 +02:00
Johan Andrén
20ab404350 Merge pull request #20297 from hepin1989/rename-flow-graph-things 
= rename FlowGraph* to GraphDSL
 2016-04-18 15:29:59 +02:00
zhxiaog
7207189d6a convert Recover to GraphStage 2016-04-18 15:23:05 +08:00
Konrad Malawski
e5cfe5b0ed +htp,str #20326 more links to ssl-config and update default TLS version 2016-04-15 16:04:56 +02:00
Viktor Klang
455805cda9 Converts the Scan-operation from PushPullStage to GraphStage 2016-04-15 10:51:24 +02:00
hepin1989(虎鸣)
e9670ee91d = rename FlowGraph* to GraphDSL 2016-04-15 00:18:05 +08:00
Michał Płachta
8376fa8cfd Replace PushStage-based Filter with GraphStage (part of #19834) (#20269) 2016-04-14 11:04:08 +02:00
drewhk
1ebb5948b1 Merge pull request #20281 from drewhk/wip-20216-nosuchelement-graphdsl-drewhk 
#20216: Wiring should work in arbitrary nest levels far from original module
 2016-04-12 10:00:24 +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
drewhk
503a77f515 Merge pull request #20285 from drewhk/wip-20142-unbind-after-system-shutdown-drewhk 
#20142: Fix implicit sender closure in TcpConnectionsStage
 2016-04-11 14:52:26 +02:00
Endre Sándor Varga
da66d3e1cd #20142: Fix implicit sender closure in TcpConnectionsStage 2016-04-11 13:36:04 +02:00
Endre Sándor Varga
577b1e42b8 #20216: Wiring should work in arbitrary nest levels far from original module 2016-04-11 11:31:07 +02:00
Konrad Malawski
4750698a03 htp #20214 allow workaround for disabling SNI 2016-04-08 15:43:10 +02:00
Johan Andrén
825f49eae2 Merge pull request #20225 from akka/wip-17037-stash-patriknw 
str: Support stash in ActorPublisher, #17037
 2016-04-06 18:46:43 +02:00
Mark van der Tol
0a1431e5d3 htc #20228 fix race condition when setting up client https connection 2016-04-06 11:29:52 +02:00
Endre Sándor Varga
60c8648b59 20232: Fix missing last group in groupedWithin 2016-04-05 15:01:18 +02:00
Patrik Nordwall
85e06b35b1 str: Support stash in ActorPublisher, #17037 2016-04-04 15:59:52 +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
Tal Pressman
26c25c89ed +str #19390 Add 'monitor' flow combinator and stage 2016-04-01 08:06:37 +02:00
Alexander Golubev
69e6052cbe +str #18620 add Source.blocking() for legacy API integration 2016-03-31 10:29:48 -04:00
drewhk
1596ae7f13 Merge pull request #20189 from drewhk/wip-19777-truncation-exception-drewhk 
#19777 OutputTruncation should be only reported if there is proof of it
 2016-03-31 14:58:23 +02:00
Endre Sándor Varga
4b76e32058 #19777 OutputTruncation should be only reported if there is proof of it 2016-03-31 13:53:36 +02:00
drewhk
a0515780db Merge pull request #19878 from drewhk/wip-19862-throttle-div-zero-2nd-variant-drewhk 
#19862 Fix division-by zero on low rates
 2016-03-31 13:42:42 +02:00
Endre Sándor Varga
d815ed1b5e 19862 Token bucket reimplemented 2016-03-31 11:36:03 +02:00
Endre Sándor Varga
5545ff8fa7 #19862 Token bucket should start full 
- also renamed and refactored various variables for better understanding
 - added comments to explain features
 2016-03-31 11:36:02 +02:00
Endre Sándor Varga
2cb4d42087 19892: KillSwitch (controllable stream completion) 2016-03-31 10:51:59 +02:00
Johan Andrén
cb91c60266 Merge pull request #19990 from agolubev/19834-replace-collect-with-GraphStage 
19834 replace collect with graph stage
 2016-03-29 18:46:52 +02:00
Johan Andrén
2cb0f161ff str #20144 UnzipWith pushed twice when sinks were closing 2016-03-29 11:17:49 +02:00
Roland Kuhn
8a3cf8145b lift mapMaterializedValue to FlowOpsMat 2016-03-24 12:51:39 +01:00
Roland Kuhn
777a400b12 use union/diff operator on Sets (optimization) 2016-03-24 12:51:18 +01:00
Alexander Golubev
951afec88e =str 19834 Migrating PushStages to GraphStage 
Collect, DropWhile, LimitWeighted
 2016-03-22 10:44:27 -04:00
Samuel Tardieu
0b4acce4d7 =str Simplify cancellation of TickSource 
Fix #20028
 2016-03-21 19:10:17 +01:00
Konrad Malawski
30e43d05aa Merge pull request #19908 from trautonen/take-as-graphstage-trautonen 
Replaced PushStage based Take with GraphStage #19834
 2016-03-21 15:44:13 +01:00