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

627 commits

Author SHA1 Message Date
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
028440d825 #20282: Make unbind work on windows 2016-04-11 11:53:59 +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
Patrik Nordwall
790519627b Merge pull request #20240 from akka/wip-20197-FlowLimitSpec-patriknw 
increase test timeout in FlowLimitSpec, #20197
 2016-04-07 12:01:34 +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
Konrad Malawski
62d8a69fac all #20090 enable running java tests in actor,camel,cluster,persistence 2016-04-06 01:23:21 +02:00
Patrik Nordwall
6405991f86 increase test timeout in FlowLimitSpec, #20197 
* and a bunch of other 300.ms timeouts
 2016-04-05 15:57:49 +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
Konrad Malawski
3e84f45499 Merge pull request #20191 from drewhk/wip-19958-throttle-reuse-drewhk 
19958: Add tests for throttle reuse
 2016-04-01 10:40:19 +02: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
Endre Sándor Varga
8459bfaef2 19958: Add tests for throttle reuse 2016-03-31 14:23:29 +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
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
Tapio Rautonen
1bcc1310d2 Replaced PushStage based Take with GraphStage #19834 
Changes suggested by @viktorklang

Added take to binary compatibility exclude

Cleanup
 2016-03-18 21:35:05 +02:00
Johan Andrén
ed739ad970 str #20049 OutputStreamSource thread leak fixed 2016-03-18 15:32:25 +01:00
Roland Kuhn
a2c46999a8 Merge pull request #20067 from akka/wip-big-graph-tests-RK 
add tests for large flows
 2016-03-17 14:16:55 +01:00
Roland Kuhn
af310411fd add Source.queue termination support, fixes #19877 2016-03-17 12:47:06 +01:00
Roland Kuhn
aeb990deb2 add tests for large flows 2016-03-17 12:45:12 +01:00
Roland Kuhn
b255a19374 simplify materialized value computation tree, fixes #20015 
- also fixes materialized value sources for graphs that import zero or
  one graphs, with and without Fusing
 2016-03-16 17:05:46 +01:00
Konrad Malawski
65a9e0a0f9 Merge pull request #20041 from akka/wip-20031-FilePublisher-onComplete-RK 
fix ActorPublisher state machine, fixes #20031
 2016-03-15 20:42:44 +01:00
Konrad Malawski
05e63c347c Merge pull request #20040 from johanandren/wip-20039-incorrect-case-in-FixedBufferSpec-johanandren 
=str #20039 incorrect FixedBufferSpec test case fixed
 2016-03-15 17:21:54 +01:00
Roland Kuhn
19d0bdb148 fix ActorPublisher state machine, fixes #20031 2016-03-15 16:45:50 +01:00
Johan Andrén
6fb9b317c2 =str #20039 incorrect FixedBufferSpec test case fixed 2016-03-15 16:24:49 +01:00
Johan Andrén
8a9b3a48d9 =str #20009 State shared over multiple materializations eliminated 2016-03-15 15:05:01 +01:00
Alexander Golubev
b2b2ce44b5 =str #19299 Performance Flow.flatMapMerge 2016-03-14 14:14:39 -04:00
Konrad Malawski
aa9a572ffd Merge pull request #19845 from ktoso/wip-subscription-timeout-modes-ktoso 
=str #19791 subscription timeouts modes respected in prefixAndTail
 2016-03-11 15:12:53 +01:00
Konrad Malawski
9c763cc850 =str #19791 subscription timeouts modes respected in prefixAndTail 2016-03-09 19:24:07 +01:00
Johan Andrén
1c40d64d62 Merge pull request #19886 from trautonen/drop-as-graphstage-trautonen 
Replaced PushStage based Drop with GraphStage #19834
 2016-02-28 17:55:18 +01:00
Tapio Rautonen
7856916e4d Replaced PushStage based Drop with GraphStage #19834 2016-02-26 21:14:33 +02:00
Julian Tescher
af34554b19 Fix common typos 2016-02-25 09:42:10 -08:00
Roland Kuhn
45e97e8467 remove akka.stream.testkit.AkkaSpec, fixes #19879 2016-02-25 15:26:51 +01:00
Johannes Rudolph
b6cbc7f13a =all remove unused imports 2016-02-23 20:29:22 +01:00
Johan Andrén
62e30b3c08 Update copyrights and links to the new company name #19851 2016-02-23 12:58:39 +01:00
Viktor Klang
771111f40d =str - #19774 - Implements GSL.readN properly, with tests 2016-02-17 17:44:58 +01:00
Bojan Petrovic
0bc04f3466 = str #19803 fix 1 element buffer handling 
* Sink.queue and Sink.actorRefWithAck can now handle one element input
  buffers
* Sink.queue now buffers as much upstream elements as declared in its
  InputBuffer attribute, instead of one less.
* Tests for streaming with full buffer now do not depend on default
  input buffer size (16); instead, they set sink input buffer size
  explicitly.
 2016-02-16 21:59:56 +01:00
Roland Kuhn
c91fa3545e Merge branch 'tmp' 2016-02-16 21:51:04 +01:00