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

18969 commits

This branch
This branch
All branches
Author SHA1 Message Date
Alexey Noskov
2150dabdc9 Eliminate double-copy of byte array when creating ByteString with varargs 2016-04-02 12:39:12 +03:00
Konrad Malawski
8449647e40 Merge pull request #19910 from vans239/master 
Replaced PushStage based TakeWhile with GraphStage #19834
 2016-04-01 11:35:01 +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
Evgeny Vanslov
f42ab58b05 Replaced PushStage based TakeWhile with GraphStage #19834 2016-04-01 11:34:30 +03:00
Patrik Nordwall
53eb0c847a Merge pull request #20195 from akka/wip-19390-str-create-sink-recent-patriknw 
+str #19390 Add 'monitor' flow combinator and stage
 2016-04-01 09:58:28 +02:00
Tal Pressman
26c25c89ed +str #19390 Add 'monitor' flow combinator and stage 2016-04-01 08:06:37 +02:00
Konrad Malawski
bd8fcc9d9a Merge pull request #20193 from naferx/duplicates-naferx 
Remove 'the' duplicates
 2016-03-31 23:26:49 +02:00
Nafer Sanabria
b6b017902f Remove 'the' duplicates 2016-03-31 16:20:15 -05:00
Patrik Nordwall
bc660a7403 Merge pull request #20085 from agolubev/19834-Replace-UTF8Encoder-with-GraphStage 
=str #19834 Replave UTF8Encoder with GraphStage
 2016-03-31 20:45:45 +02:00
Patrik Nordwall
6675f68bf7 Merge pull request #20060 from leachbj/fix-19953-bl 
=htc #19953 Complete Promise in captureTermination onDownstreamFinish
 2016-03-31 17:58:53 +02:00
Patrik Nordwall
b49eb35283 Merge pull request #19860 from agolubev/18620-add-Source.blocking()-agolubev 
18620 add source.blocking() agolubev
 2016-03-31 17:49:38 +02:00
Alexander Golubev
bcd52fb90a =str #19834 Replave UTF8Encoder with GraphStage 2016-03-31 11:07:12 -04: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
8459bfaef2 19958: Add tests for throttle reuse 2016-03-31 14:23:29 +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
Bernard Leach
89a6187efc =htc #19953 Complete Promise in captureTermination onDownstreamFinish 
PoolSlot uses StreamUtils.captureTermination to determine when the
associated request is completed, when a request from the pool was
subsequently used as a response by a server Flow the rendering
process would cancel the subscription to the Source but that
would not complete the Promise in StreamUtils.captureTerminate and so
the SlotEvent.RequestCompleted would not be generated.
 2016-03-31 22:15:58 +11:00
Konrad Malawski
ca61a4eec4 Merge pull request #20181 from lolski/lolski-issue-19976-javadsl-wip 
Adding HTTP Java DSL
 2016-03-31 13:09:27 +02:00
drewhk
cc5adc632c Merge pull request #19895 from drewhk/wip-19892-killswitch-drewhk 
#19892: KillSwitch (externally controllable stream completion)
 2016-03-31 12:10:58 +02:00
drewhk
982243b49a Merge pull request #19913 from vans239/19910-checkContentLength 
Replaced PushStage based CheckContentLength with GraphStage #19834
 2016-03-31 11:55:08 +02:00
Patrik Nordwall
d4b53eb12d Merge pull request #20084 from samueltardieu/better-exception-message 
=act #19901 Include actor path in ActorInitializationException message
 2016-03-31 11:37:18 +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
Patrik Nordwall
23be2ee751 Merge pull request #20089 from agolubev/19834-replace-PrepareForUserHandler-with-GraphStage-agolubev 
19834 replace prepare for user handler with graph stage agolubev
 2016-03-31 11:30:41 +02:00
Endre Sándor Varga
2cb4d42087 19892: KillSwitch (controllable stream completion) 2016-03-31 10:51:59 +02:00
Ganeshwara
d08069ac08 adding java dsls 2016-03-30 10:41:00 +00:00
Alexander Golubev
b662536e7d =str #19834 replace PrepareForUserHandler with GraphStage 2016-03-29 13:54:29 -04: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
7c64ed02a3 Merge pull request #20050 from johanandren/wip-20017-stream-rate-docs-async-johanandren 
=doc #20017 Update the stream-rate docs to current streams behavior
 2016-03-29 18:04:57 +02:00
Johan Andrén
72245ad23f Merge pull request #20155 from johanandren/wip-20144-unzipwith-push-twice-johanandren 
str #20144 UnzipWith pushed twice when sinks were closing
 2016-03-29 15:11:44 +02:00
Konrad Malawski
0e2bd4e695 Merge pull request #20139 from venilnoronha/media-type-text-markdown 
Added markdown file type to MediaType text/markdown entry
 2016-03-29 13:37:09 +02:00
Johan Andrén
d72848f22f =doc #20017 Update the stream-rate docs to current streams behavior 2016-03-29 12:26:02 +02:00
Konrad Malawski
27e3c5d925 Merge pull request #20143 from akka/wip-document-flowops-extension-RK 
document FlowOps extension
 2016-03-29 12:07:30 +02:00
Konrad Malawski
0682489a77 Merge pull request #20087 from akka/wip-ws-streamed-matchable-ktoso 
+htc #20086 make ws.*Message.Streamed not private
 2016-03-29 11:58:30 +02:00
Johan Andrén
2cb0f161ff str #20144 UnzipWith pushed twice when sinks were closing 2016-03-29 11:17:49 +02:00
Konrad Malawski
6873c518ef Merge pull request #20148 from Jaca777/jaca777-4761866 
=doc #20133 Fixed doc about futures
 2016-03-29 10:14:19 +02:00
Konrad Malawski
efab2c9252 Merge pull request #20152 from sbrunk/doc-fixes 
Fix a few typos in the docs
 2016-03-28 23:01:12 +02:00
Evgeny Vanslov
45a2440970 Replaced PushStage based CheckContentLength with GraphStage #19834 2016-03-28 23:50:08 +03:00
Sören Brunk
d332428fac Fix a few typos in the docs 2016-03-28 22:06:00 +02:00
Jaca777
2984022ccc =doc #20133 Fixed doc about futures 2016-03-26 13:25:46 +01:00
Roland Kuhn
5accba105d document FlowOps extension 2016-03-25 10:13:11 +01:00
Venil Noronha
0ca2c95680 Added markdown file type to MediaType text/markdown entry 2016-03-25 02:41:17 +05:30
Konrad Malawski
aff158cb98 Merge pull request #20070 from akka/wip-random-findings-RK 
some random findings
 2016-03-24 20:24:42 +01:00
Konrad Malawski
10fbc41d13 Merge pull request #20130 from venilnoronha/media-type-text-markdown 
Added text/markdown to MediaType
 2016-03-24 16:46:58 +01:00
Venil Noronha
dc397954ea Fixes #20126 - Added text/markdown to MediaType 2016-03-24 18:13:36 +05:30
Patrik Nordwall
889db0ddb1 Merge pull request #20117 from raboof/arnoutEngelen2033 
Improve error when Cluster MBean is gone #2033
 2016-03-24 13:29:57 +01:00
Patrik Nordwall
84fc35ce20 Merge pull request #20119 from sbrunk/doc-typos 
Fix typo in persistence docs
 2016-03-24 13:28:44 +01: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