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

94 commits

Author SHA1 Message Date
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
Endre Sándor Varga
14b70836a7 #20573 Fixing wrong initial buffer sizes in delay, and one logic bug 2016-05-24 11:42:17 +02:00
Samuel Tardieu
e0c64f59d8 =str #20550 only accept -1 for infinite retries in recoverWithRetries (#20555) 2016-05-19 11:45:31 +02:00
2beaucoup
e5c0872603 =str remove unused akka.stream.impl.fusing.Completed (#20468) 2016-05-06 23:58:01 +02:00
2beaucoup
bc7cd17bee =htc Various minor cleanups (#20451) 
* minor fixes

* remove now superfluous buffer from MultipartUnmarshaller

* remove unused TokenSourceActor

* remove FIXME: add tests, see #16437

* removed unused param remoteAddress (comment: TODO: remove after #16168 is cleared)

* convert FIXME to TODO (#18709)

* reenable tests in {Request|Response}RendererSpec due to fixed #15981

* remove logging workaround in StreamTestDefaultMailbox due to fixed #15947
 2016-05-06 10:32:06 +02:00
Priyanka Chordia
1f8225087f Convert Completed from PushPullStage to GraphStage (#20454) 2016-05-05 11:49:02 +02:00
David Knapp
c72890b113 Str #20217 If the future in mapAsync is already available, don't dispatch it (#20375) 2016-04-28 22:23:03 +02:00
Konrad Malawski
0e11ec2057 !htc #20371 allows for simple HTTPS usage from Java, fixes typo in APIs (#20373) 2016-04-25 12:01:03 +02:00
Patrik Nordwall
dfbcd948bf Merge pull request #20325 from akka/wip-convert-scan-to-graphstage-√ 
Converts the Scan-operation from PushPullStage to GraphStage
 2016-04-20 15:37:16 +02:00
David Knapp
d7fe98e1c4 #20123 Added recoverWithRetries which adds a parameter to limit the (#20137) 
number of attempts. Existing recoverWith method behavior remains unchanged.
 2016-04-20 15:24:12 +02:00
zhxiaog
7207189d6a convert Recover to GraphStage 2016-04-18 15:23:05 +08:00
Viktor Klang
455805cda9 Converts the Scan-operation from PushPullStage to GraphStage 2016-04-15 10:51:24 +02:00
Michał Płachta
8376fa8cfd Replace PushStage-based Filter with GraphStage (part of #19834) (#20269) 2016-04-14 11:04:08 +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
Endre Sándor Varga
60c8648b59 20232: Fix missing last group in groupedWithin 2016-04-05 15:01:18 +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
Evgeny Vanslov
f42ab58b05 Replaced PushStage based TakeWhile with GraphStage #19834 2016-04-01 11:34:30 +03:00
Alexander Golubev
69e6052cbe +str #18620 add Source.blocking() for legacy API integration 2016-03-31 10:29:48 -04:00
Alexander Golubev
951afec88e =str 19834 Migrating PushStages to GraphStage 
Collect, DropWhile, LimitWeighted
 2016-03-22 10:44:27 -04: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
Tapio Rautonen
7856916e4d Replaced PushStage based Drop with GraphStage #19834 2016-02-26 21:14:33 +02: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
Alexander Golubev
2a36859578 =str #19423 add satefulMapConcat 2016-02-11 22:57:50 -05:00
Alexander Golubev
5a8f4135b7 +str #18045 add recoverWith(Source) 2016-02-11 10:36:40 -05:00
Roland Kuhn
c136c06f76 Merge pull request #19703 from akka/wip-19702-maxFixedBufferSize-RK 
add maxFixedBufferSize materializer setting #19702
 2016-02-11 08:41:29 +01:00
Roland Kuhn
d0e6f46f14 add maxFixedBufferSize materializer setting #19702 2016-02-10 20:55:50 +01:00
Johan Andrén
f042204d8b Merge pull request #19711 from johanandren/wip-19710-scala-types-attributes-java-api-johanandren 
!str #19710 Use Java types in Attributes Java API
 2016-02-10 13:15:14 +01:00
Johan Andrén
300ac802a0 =str #19721 Failing FlowConflateSpec and NPE in Batch fixed 2016-02-09 17:36:20 +01:00
Johan Andrén
0919889e74 !str #19710 Use Java types in Attributes Java API 2016-02-08 18:58:00 +01:00
Johan Andrén
db0274d3d6 =str #19552 Replacing Conflate with Batch 2016-02-05 10:10:24 +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
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
7e488001cc +str #16610 minor fixes 2016-01-21 09:02:35 +02: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
Konrad Malawski
96b5ca2a0a +htc add BiDiFlow.identity in JavaDSL 2016-01-20 00:50:39 +01:00
Viktor Klang
58510a2b3f Minor streams touchups 2016-01-19 16:14:34 +01: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
lolski
aadaf15b89 #18021 Sink.seq and FlowOps.limit and .limitWeighted 2015-12-20 11:00:06 +01:00
Roland Kuhn
a20bbce433 add fusing 2015-12-15 09:24:52 +01:00
Roland Kuhn
1c18eafcbe Merge pull request #19153 from akka/wip-19149-fix-flowOps-sliding-√ 
=str - 19149 - Corrects the behavior of FlowOps.sliding
 2015-12-13 16:45:59 +01:00
Viktor Klang
108f6749de =str - 19149 - Corrects the behavior of FlowOps.sliding 
Generatively attempts to verify that it behaves exactly like the
collections library

Removes the use of Vector.builder for an easier-to-follow Vector
implementation while waiting for this to be reimplemented as a
GraphStage.

Also, the Builder implementation relies on undefined behavior:

"Builder.result() — Produces a collection from the added elements.
The builder's contents are undefined after this operation." -
http://www.scala-lang.org/api/current/#scala.collection.mutable.Builder
 2015-12-12 20:20:16 +01:00
Roland Kuhn
8e62368afe Merge branch 'release-2.3-dev' of github.com:akka/akka into release-2.3-dev 2015-12-12 16:59:53 +01:00
Roland Kuhn
819c1ef504 Merge remote-tracking branch 'pr/18985' into release-2.3-dev 2015-12-12 16:59:05 +01:00