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

103 commits

Author SHA1 Message Date
Roland Kuhn
af310411fd add Source.queue termination support, fixes #19877 2016-03-17 12:47:06 +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
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
Roland Kuhn
7b7647435b ensure that graph attributes are not lost 
- this entails making Module.isSealed==true if attributes are set
- also removed Module.nest(), which implied fixing replaceShape to form
  a CompositeModule where CopiedModule was used before (GraphModule and
  TlsModule)
 2016-02-12 10:07:55 +01:00
Johan Andrén
4e49d75ad8 !str #19732 Concise and consistent way to mark async boundaries 2016-02-11 18:20:23 +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
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
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
Viktor Klang
58510a2b3f Minor streams touchups 2016-01-19 16:14:34 +01:00
Endre Sándor Varga
b217e2e480 #19440 Added scala-java8-compat as a dependency to streams 2016-01-14 12:01:36 +01:00
Roland Kuhn
3267d58e5d Merge pull request #19407 from akka/wip-optimize-repeat-√ 
=str - Change implementation of Source.repeat to use unfold
 2016-01-14 08:09:04 +01:00
Viktor Klang
2b1d22a785 =str - Change implementation of Source.repeat to use unfold 2016-01-12 10:52:09 +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
Viktor Klang
22ccbcea39 =str - Significant simplification of the implementation of Source.unfoldInf 2016-01-12 10:22:12 +01:00
Viktor Klang
59bff70c87 =str - 16503 - Implements a dedicated FutureSource 
Avoids the overhead of
`Source.single(future).mapAsyncUnordered(1)(identity).withAttr…`

Fixes #16503
 2016-01-06 13:01:37 +01:00
Roland Kuhn
8a5a420108 #19261 override and test addAttributes compilation 2015-12-22 20:56:02 +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
Endre Sándor Varga
b478d70964 !str #19137: Rename inlet and outlet to in and out on Flow/Source/SinkShape 2015-12-15 16:49:52 +01:00
Roland Kuhn
a20bbce433 add fusing 2015-12-15 09:24:52 +01:00
Gilad Hoch
e8e52acc58 =str fixing documentation for PR #19143 2015-12-14 13:28:21 +02: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
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
Roland Kuhn
f00da4daac !str #19037 rename FlowGraph to GraphDSL 2015-12-01 18:30:07 +01:00
Viktor Klang
8780ba28a4 !str - Moving the InputStream and OutputStream utilities into Source and Sink 2015-11-18 09:13:57 +01:00
Viktor Klang
20c996fe41 !str - 18916 - Source.file and Sink.file 
* Removes `Synchronous` from the names and descriptions of File I/O as it leaks impl details
* Removes the factries for FileSource and FileSink and puts them in Source and Sink respectively
 2015-11-17 09:50:10 +01:00
Martynas Mickevičius
ee5ec72552 =str #15707 name unnamed modules 
* give name attribute to TickSource and nested modules
* reflow module toString output
* give toString to flow
 2015-11-04 13:01:05 +02:00
Roland Kuhn
556012b7ee !str,htc replace and remove OneBoundedInterpreter 
main work by @drewhk with contributions from @2m and @rkuhn

This work uncovered many well-hidden bugs in existing Stages, in
particular StatefulStage. These were hidden by the behavior of
OneBoundedInterpreter that normally behaves more orderly than it
guarantees in general, especially with respect to the timeliness of
delivery of upstream termination signals; the bugs were then that
internal state was not flushed when onComplete arrived “too early”.
 2015-11-01 14:53:52 +01:00
Viktor Klang
f29d7affbd !str #18692 javadsl.FlowGraph.Builder.add() 
* also make factories more consistent by only offering
  FlowGraph.create()
* also remove secondary (edge-based) FlowGraph.Builder DSL
* also improve naming for conversions from Graph to
  Source/Flow/BidiFlow/Sink
 2015-10-22 19:10:00 +02:00
Roland Kuhn
684f3e3175 Merge pull request #18697 from agolubev/agolubev-#18133-Sink.actorSubscriber()-verify-props 
=str #18133 Sink.actorSubscriber() should verify the props
 2015-10-21 18:56:28 +02:00
Konrad Malawski
61c2213e02 +str #17383 implement intersperse 2015-10-19 13:17:23 +02:00
Alexander Golubev
53d0627675 =str #18133 Sink.actorSubscriber() should verify the props 2015-10-09 15:11:01 -04:00
Alexander Golubev
c8428a1bc3 +str #18411 add FlowOps.zip/zipWith/merge/concat operators 2015-10-03 23:26:06 -04:00
Alexander Golubev
993e545e99 +str #18411 add FlowOps.zip/zipWith/merge/concat operators 2015-10-03 14:28:57 -04:00
kukido
f858881b2e =doc #17329 Spelling normalization, typos fixed. 2015-09-28 22:45:38 -07:00
Endre Sándor Varga
eec8bd689f =str: TickSource is now a GraphStage 2015-09-21 10:30:14 +02:00
Endre Sándor Varga
12c9abb8c9 !str #16410 #16597: Removed TimerTransform, added Timeout stages 2015-09-18 12:38:36 +02:00
Endre Sándor Varga
174589f2dc =str: GraphStage improvements 2015-09-17 10:08:12 +02:00
Alexander Golubev
38fe35d668 +str #17693 add Source.queue and Sink.queue 2015-09-04 12:50:05 -04:00
Alexander Golubev
7620014358 +str #17399 add boilerplate remover for fan-in junctions 2015-09-01 09:51:23 -04:00
Viktor Klang
66a116d3d2 -str - Improvements and renames in internal streams classes 
* Renames Module.grow -> Module.compose
 * Renames Module.connect -> Module.wire
 * Renames Module.growConnect -> Module.fuse
 * Renames Module.wrap -> Module.nest

 * Adds explicit identity equals and hashCode to InPort and OutPort

 * Reimplements many of the Source factories to avoid copying

 * Documents Module.compose, Module.fuse, Module.wire and Module.nest

 * Removes Attributes.nameLifted

 * Optimizes Attributes.nameOrDefault
 2015-07-13 23:39:45 +02:00
Martynas Mickevičius
efc659b70a Merge pull request #17953 from drewhk/wip-17891-processor-support-drewhk 
+str #17891: Add direct support for RS Processors
 2015-07-13 17:21:10 +03:00
Endre Sándor Varga
47ea3fde38 created factory method 2015-07-09 18:01:45 +02:00
Endre Sándor Varga
333a006bf1 +doc #17569: Mention no support of "backpressure" strategy on Source.actorRef 2015-07-09 10:18:18 +02:00
Viktor Klang
2725bfc044 =str - Various internal Akka Stream improvements 
* Gives Inlets and Outlets a `carbonCopy` method and switches to allocate them via `apply`
* Removes 4 Array allocations per FanIn and uses a bitmasked array instead
* Makes the FlattenStrategy.concat instance a singleton
 2015-06-30 11:45:50 +02:00