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

147 commits

Author SHA1 Message Date
drewhk
a799aa5591 Merge pull request #19665 from dorin-cbz/master 
Correct typo in 'Source.from()' function documentation
 2016-02-08 12:38:53 +01:00
Dorin Cobzac
dbc41d5a90 =str - correct typo in 'Source.from()' function documentation 2016-02-05 19:12:04 +02:00
Johan Andrén
8c60ad0a02 !str #19698 Remove tuple from Java API Source signatures 2016-02-05 17:04:50 +01:00
Endre Sándor Varga
3081e2895b 19455 Simplify conflate signature for the common case 2016-02-04 16:06:23 +01:00
Johan Andrén
f008a932c3 Merge pull request #19603 from akka/wip-19068-2016-copyrights-johanandren 
=pro #19068 All copyrights ranges updated with 2016
 2016-01-25 12:07:42 +01:00
Roland Kuhn
d49d2545ec convert watchTermination to CompletionStage for Java 2016-01-25 11:14:31 +01:00
drewhk
41d8b1fadd Merge pull request #19498 from agolubev/agolubev-#18565-TerminationNotification-combinator 
+str #18565 termination notification combinator
 2016-01-25 10:52:48 +01:00
Prayag Verma
b7783968a0 =pro #19068 All copyrights ranges and single years updated to a range ending in 2016 2016-01-25 10:20:30 +01:00
Roland Kuhn
4c72495581 #19440 replace Scala Future usage with CompletionStage in javadsl 
This entails:

  * adding akka.pattern.PatternCS.* to enable ask etc. with
    CompletionStage
  * changing RequestContext to offer an ExecutionContextExecutor for the
    CompletionStage.*Async combinators
  * splitting up akka.stream.Queue for JavaDSL consistency
 2016-01-23 18:00:11 +01:00
Alexander Golubev
98c72e7d13 +str #18565 termination notification combinator 2016-01-22 16:45:54 -05:00
Roland Kuhn
ba14bb4f3f Merge pull request #19489 from agolubev/agolubev-#18890_polish-Source.queue 
Agolubev #18890 polish source.queue
 2016-01-22 08:39:53 +01:00
Alexander Golubev
a2ab7f29e1 +str #19020 reduce combinator 2016-01-21 22:16:37 -05:00
Alexander Golubev
d5f81e19d1 =str #18890 Polish Source.queue 2016-01-21 13:09:55 -05:00
Gilad Hoch
fde0c11fff +str #16610 added javadsl tests + conflate now delegates to Batch + most of the changes @drewhk & @rkuhn suggested 2016-01-21 08:44:31 +02:00
Gilad Hoch
b420d6a472 +str #16610 applied the changes suggested by @drewhk 2016-01-21 08:44:30 +02:00
Gilad Hoch
d690067fc9 +str #16610 adding aggregate & aggregateWeighted ops 2016-01-21 08:44:30 +02:00
Roland Kuhn
7463c50fc9 #19444 simplify signature of FlowOps.expand 
Any previous usage can be represented in this fashion while typically
saving one function allocation and also saving the function literal’s
syntax overhead (for the seed). Plus a new feature: the provided
iterator does not have to be infinite, limiting how far expand is
allowed to go.
 2016-01-20 09:27:45 +01:00
Endre Sándor Varga
60497f6561 also fix FlowInterleaveSpec 
Also-by: Johan Andrén <johan@markatta.com>
Also-by: Roland Kuhn <rk@rkuhn.info>
Also-by: Martynas Mickevičius <mmartynas@gmail.com>
 2016-01-20 10:01:58 +02:00
Endre Sándor Varga
7a39063f2e #19441: Use Optional instead of Option in javadsl 2016-01-15 14:38:05 +01:00
Viktor Klang
d65efc35c7 -str - Removes Source.unfoldInf 
Motivation: Since it can be easily implemented inline on top of unfold
 2016-01-12 10:22:19 +01:00
Roland Kuhn
a733096564 #19267 add .viaAsync combinator 2015-12-22 22:27:51 +01:00
Roland Kuhn
8a5a420108 #19261 override and test addAttributes compilation 2015-12-22 20:56:02 +01:00
Roland Kuhn
b0b03176ae #19238 add detach operator and fix Detach stage 2015-12-20 11:25:53 +01:00
lolski
aadaf15b89 #18021 Sink.seq and FlowOps.limit and .limitWeighted 2015-12-20 11:00:06 +01:00
Iain Monro
52655f2836 +str #19069 Add FlowOp.prepend for prepending Sources to Flows 2015-12-20 09:55:45 +01:00
Johan Andrén
09a79f45e4 !str #19129 New homes for file and java.io stream factories 2015-12-17 14:41:02 +01:00
Martynas Mickevičius
e6e476d82a =str #19128 #19127 rename Source/Sink factory apply overloads 2015-12-17 11:48:30 +02:00
Konrad Malawski
08d0f2290d Merge pull request #19165 from hochgi/hochgi-unfold-docs-fixes 
=str fixing documentation for PR #19143
 2015-12-14 11:36:42 +00:00
Gilad Hoch
e8e52acc58 =str fixing documentation for PR #19143 2015-12-14 13:28:21 +02:00
Roland Kuhn
ff351338d2 Merge pull request #19155 from akka/wip-18962-MergeSorted-RK 
#18962 MergeSorted and read() completion handling
 2015-12-14 12:21:52 +01:00
Roland Kuhn
ac83b1965c #18962 MergeSorted and read() completion handling 2015-12-14 12:21:30 +01:00
Roland Kuhn
5c55180327 Merge pull request #19143 from hochgi/hochgi-19021-unfold 
+str #19021 Add unfold (and variants) generators to Source
 2015-12-14 11:43:49 +01:00
Gilad Hoch
5f748e3711 +str #19021 Add unfold (and variants) generators to Source 2015-12-14 11:57:01 +02:00
Roland Kuhn
fda9c5d1b8 Merge pull request #19140 from agolubev/agolubev-#19041-determenistic-interleave 
+str #19041 deterministic `interleave` operation
 2015-12-14 07:26:54 +01:00
Roland Kuhn
d5d099725a Merge pull request #19038 from agolubev/agolubev-#18807-range-Source-for-Java-DSL 
+str #18807 add Source.range for Java DSL
 2015-12-12 17:38:12 +01:00
Roland Kuhn
819c1ef504 Merge remote-tracking branch 'pr/18985' into release-2.3-dev 2015-12-12 16:59:05 +01:00
Alexander Golubev
fe3c34ed00 +str #19041 deterministic interleave operation 2015-12-10 21:46:48 -05:00
Alexander Golubev
737e7b8dfc +str #19041 deterministic interleave operation 2015-12-10 21:46:47 -05:00
Roland Kuhn
1500d1f36d !str #19005 make groupBy et al return a SubFlow 
A SubFlow (or SubSource) is not a Graph, it is an unfinished builder
that accepts transformations. This allows us to capture the substreams’
transformations before materializing the flow, which will be very
helpful in fully fusing all operators.

Another change is that groupBy now requires a maxSubstreams parameter in
order to bound its resource usage. In exchange the matching merge can be
unbounded. This trades silent deadlock for explicit stream failure.

This commit also changes all uses of Predef.identity to use `conforms`
and removes the HTTP impl.util.identityFunc.
 2015-12-10 12:27:16 +01:00
Alexander Golubev
357af9c388 +str #18807 Source.range for Java DSL 2015-12-04 09:46:50 -05:00
Alexander Golubev
5aa83594fa +str #18556 add delay combinator 2015-12-02 14:58:30 -05:00
Alexander Golubev
89d32f6f09 +str #18807 Source.range for Java DSL 2015-12-02 11:20:47 -05:00
Roland Kuhn
073e7058dc !str #15089 add flatMapMerge 2015-12-02 09:01:20 +01:00
Alexander Golubev
9597b00f70 +str #18807 add Source.range for Java DSL 2015-11-28 21:50:09 -05:00
Alexander Golubev
18f1bc73fe +str #18807 add Source.range for Java DSL 2015-11-27 22:24:24 -05:00
drewhk
2308930977 Merge pull request #18887 from agolubev/agolubev-#18555_add_throttle_combinator 
=str #18555 add throttle combinator
 2015-11-27 10:16:04 +01:00
Alexander Golubev
83d3143236 +str #18556 add delay combinator 2015-11-26 15:58:38 -05:00
Alexander Golubev
ea6488c6c0 +str #18555 add throttle combinator 2015-11-23 11:49:11 -05:00
Alexander Golubev
270ef41359 =str #18556 add delay combinator 2015-11-21 13:48:10 -05:00
Viktor Klang
8780ba28a4 !str - Moving the InputStream and OutputStream utilities into Source and Sink 2015-11-18 09:13:57 +01:00