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

67 commits

Author SHA1 Message Date
Alexander Golubev
eff6c409d1 +str fix for "fail offer future when stream is completed" QueueSource/SinkSpec 2017-08-19 23:25:18 -04:00
Johan Andrén
87b28d0dc5 Fail all stages on abrupt termination #22652 2017-04-28 11:11:50 +02:00
Johan Andrén
d5459222aa Substream materialization failure test coverage and fix #22646 2017-04-03 20:21:02 +02:00
Martynas Mickevičius
2a9c0370e0 Add @InternalApi annotations and private markers on internal apis (#22563) 
* #22506 Mark materializer extension as @InternalApi

* #22506 Added missing annotations on internal apis in the fusing package

* #22506 Missing annotations in io package

* #22506 Add internal api annotations in impl package

* #22563 more hiding of the classes in the impl package

* #22563 Formatting fixes

* #22506 Fix private access in stream tcl tests
 2017-03-16 20:04:07 +01:00
Konrad `ktoso` Malawski
e2a15a2a58 =str use OptionVal in Traversal building 2017-03-10 11:45:26 +01:00
drewhk
87d5b8f627 Wip fix islands drewhk (#22475) 
* Fixed island application

* Switched to explicit island boundaries and fixed misapplied island tags

* Added missing attributes for non-stage backed Sinks
 2017-03-07 14:26:18 +01:00
drewhk
b33339f13e Make flowspec great again drewhk (#22443) 
* #22435: Make DirectProcessorModule work again

* #22435: Fix attributes propagation for FanoutProcessor

* #22435: Remove old "faulty-flow" spec
 2017-03-03 10:49:34 +01:00
Endre Sándor Varga
ba63c7af8d New materializer and layout 2017-03-01 16:18:55 +01:00
Alexander Golubev
552481b511 #22030 Lazy sink wait for init 2017-02-16 09:19:25 +01:00
Philippus Baalman
6c7085252a extended copyright into 2017 2017-01-04 17:37:15 +01:00
Ortigali
f970412af7 Rewrite Sink.ignore as a GraphStage #21527 2016-10-26 12:38:49 +02:00
Cédric Chantepie
324a40ba97 =str Refactoring to avoid distinct handler instantiation for stage logics (#21309) 
* Refactoring to avoid distinct handler instantiation for stage logics

* setHandlers
 2016-08-29 13:00:48 +01:00
Patrik Nordwall
b4cd30cf94 Merge pull request #20757 from kkasravi/issue_20543_kkasravi 
Fixes #20543 GraphStage subtypes should not be private to akka
 2016-07-08 10:06:27 +02:00
Alexander Golubev
e0562abba9 +str 20129 add lazySink (#20579) 2016-07-07 13:01:28 +02:00
Kam Kasravi
1d692daaad Fixes #20543 GraphStage subtypes should not be private to akka 2016-07-05 17:12:35 -07:00
Kam Kasravi
049b95077f fixes #20414 Allow different ActorMaterializer subtypes 2016-06-07 07:13:03 -07:00
Björn Antonsson
c66ce62d63 Update to a working version of Scalariform 2016-06-02 22:12:36 +02:00
Alexander Golubev
03395d5739 =str #20229 groupBy should be a Graph stage (#20344) 2016-05-23 10:31:49 +02:00
Endre Sándor Varga
093d82ce00 +str #19443 add support or Java Stream 2016-04-29 23:31:56 -04: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
Roland Kuhn
9db36727c0 fix and document VirtualProcessor, fixes #19790 2016-03-09 13:19:40 +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
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
2bb45ce211 Merge pull request #19783 from ALPHA-60/fix-ignore-zero-sized-buffer 
=str #19781 Use overriden `InputBuffer` attribute
 2016-02-16 10:31:17 +01:00
Bojan Petrovic
b4f507cdd6 =str #19781 Use overriden InputBuffer attribute 
* Sink.{queue, actorRefWithAck} and StreamConverters.{asInputStream,
  asOutputStream} now use overriden/inherited `InputBuffer` attribute
* They now use their default attributes as initial attributes.
 2016-02-15 21:31:13 +01:00
Viktor Klang
365e6243b3 = - Minor cleanups, will get an appropriate commit message soon 2016-02-15 21:01:28 +01:00
Roland Kuhn
432b77a9a2 Merge pull request #19619 from agolubev/agolubev-#19291-TestGraphStage 
=str #19291 add TestGraphStages for Sink and Source
 2016-02-12 14:30:29 +01:00
drewhk
ebb915ae4d Merge pull request #19750 from lolski/lolski-issue-19293-rebased 
=str #19293 fix issues in Sink.seq + minor doc fixes + use Sink.seq
 2016-02-12 11:36:56 +01:00
Roland Kuhn
f713a5eaef Merge pull request #19676 from ALPHA-60/fix-sink-queue-buffer 
fix Sink.queue when buffer has run full #19675
 2016-02-11 20:10:18 +01:00
lolski
21381d5710 =str #19293 fix issues in Sink.seq + minor doc fixes + use Sink.seq and limit in tests where appropriate 
* Sink.seq (Scala DSL) now returns immutable.Seq rather than Seq
* Sink.seq will not silently truncate when incoming elements is > Int.MAX_VALUE
* minor doc fixes
* replacing various grouped(n) / Sink.head with limit(n) / Sink.seq in various tests
* fix inconsistent indentation in RequestParserSpec
 2016-02-12 01:36:21 +08:00
Bojan Petrovic
fa3b36dcee fix Sink.queue when buffer has run full #19675 2016-02-10 23:20:28 +01:00
Roland Kuhn
d0e6f46f14 add maxFixedBufferSize materializer setting #19702 2016-02-10 20:55:50 +01:00
Alexander Golubev
a10bba9c84 =str #19291 add TestGraphStages for Sink and Source 2016-01-26 11:47:30 -05: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
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
Roland Kuhn
469e15581f fusable SplitWhen and reusable HTTP blueprint 
plus further optimizations

Lots of contributions from drewhk (Endre Varga).
 2015-12-21 12:28:21 +01:00
Roland Kuhn
dcfa56e547 Merge remote-tracking branch 'pr/19097' into release-2.3-dev 2015-12-18 12:22:02 +01:00
Alexander Golubev
64387583ad =str #18821 fix Sink.queue termination 2015-12-16 17:53:36 -05: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
Johan Andrén
bcc3525bd9 !str #19156 Source/Flow/Sink-Stage removed 2015-12-14 15:29:04 +01:00
Viktor Klang
94fe1fb26d +str - Adds Sink.last and Sink.lastOption to mirror Sink.head and Sink.headOption 
* Renames BlackholeSubscriber to SinkholeSunbscriber
* Makes SinkholeSubscriber request Long.MaxValue
* SinkholeSink seems like the best name ever
 2015-11-18 21:48:00 +01:00
Konrad Malawski
8650d0c473 +str #18906 add Sink.headOption 2015-11-14 16:36:09 +01:00
Viktor Klang
6cfa4df800 !str - Switches Sink.publisher to use a boolean to indicate fanout rather than a number of allowed subscribers 2015-11-04 12:29:23 +01:00
Viktor Klang
f839a1f85d !str - 18808 - Removes Sink.fanoutPublisher and makes Sink.publisher specify number of subscribers 
Sink.publisher now takes a max number of Subscribers and
the elasticity between concurrent Subscribers.
 2015-11-04 12:29:07 +01:00
Alexander Golubev
38fe35d668 +str #17693 add Source.queue and Sink.queue 2015-09-04 12:50:05 -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