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

23108 commits

This branch
This branch
All branches
Author SHA1 Message Date
Christopher Batey
f2708c9dd3
Remove outdated comment from build.properties (#26475) 2019-03-06 15:15:46 +00:00
Johannes Rudolph
f1872b773c
Merge pull request #26474 from jrudolph/jr/26330-remove-WithContext-statefulMapContext 
!str remove {Source,Flow}WithContext.statefulMapConcat, fixes #26330
 2019-03-06 13:19:25 +01:00
Johannes Rudolph
45fa9dd552
!str remove {Source,Flow}WithContext.statefulMapConcat, fixes #26330 
statefulMapConcat will by design confound processing of single elements.
However, in the WithContext APIs the user only has access to the elements
but not to the contexts so the association is likely to be wrong in the end.

So, for now, we follow our basic rule not to include potentially order-changing
operations in the WithContext APIs and remove statefulMapConcat. Users that
need something like that should drop to the regular tuple passing APIs and
manage context propagation manually.
 2019-03-06 11:53:41 +01:00
Johan Andrén
7900240eb3 Access latestSeqNr in typed persistence (#26261) 2019-03-06 11:27:35 +01:00
Johannes Rudolph
c186c1bde9
Merge pull request #26447 from zhongl/name-typo 
Fix typos of OutgoingConnectionStage's port names
 2019-03-06 10:33:24 +01:00
Johan Andrén
d52d0c1cce
Merge pull request #26469 from ennru/fix-dead-links 
Fix dead links in the docs
 2019-03-06 09:57:58 +01:00
Enno Runne
066a692ca1 Fix dead links in the docs 2019-03-05 17:30:27 +01:00
Johan Andrén
aebef217d7
Use AsyncDnsCache directly in DnsServiceDiscovery, #25948 2019-03-05 14:24:08 +01:00
Johannes Rudolph
971bd5159e
act Avoid deadletter access if not needed (#26422) 2019-03-05 14:09:38 +01:00
Helena Edelson
27957649e8
Consolidate duplicate persistence sharding function #26451 (#26452) 2019-03-05 08:05:51 -05:00
Patrik Nordwall
7f0837a550
Merge pull request #26465 from akka/wip-from-tuple-pair-source-patriknw 
Adds fromPairs to SourceWithContent object
 2019-03-05 11:56:44 +01:00
Patrik Nordwall
6071d890aa
Merge pull request #26464 from akka/wip-toMap-withContext-patriknw 
Adds to and toMap to SourceWithContext
 2019-03-05 10:06:27 +01:00
Luc Bourlier
c344287b9d Adds fromPairs to SourceWithContent object 
Like in FlowWithContext. To simplify the creation of sourceWithContext
from sources with compatible types.
Renames from to fromPairs in FlowWithContext.
 2019-03-05 09:56:24 +01:00
Patrik Nordwall
74b2144038
Merge pull request #26462 from akka/wip-26411-withAttributes-withContext-patriknw 
Sets correct return type for withAttributes on Source/FlowWithContext
 2019-03-05 09:18:19 +01:00
Patrik Nordwall
a0daf3e5eb add runWith to SourceWithContext 2019-03-05 09:17:52 +01:00
Luc Bourlier
a98daa0d08 Adds to and toMap to SourceWithContext 2019-03-05 08:40:18 +01:00
Luc Bourlier
c58d348b2a Sets correct return type for withAttributes on Source/FlowWithContext 2019-03-05 08:25:27 +01:00
Johan Andrén
1a8313ba72 Fixing compilation error regarding to and from context propagated source (#26461) 2019-03-04 14:32:01 -05:00
Johan Andrén
85143b5660
Adds Flow.asFlowWithContext #26372 2019-03-04 16:32:43 +01:00
Luc Bourlier
5a425c1dc7 Rename start/endContextPropagation functions to asFlow/Source.. (#26353) 
To match FlowWithContext.asFlow
 2019-03-04 15:48:24 +01:00
Hungai Amuhinda
ff9289a089 Doc changes on supervising example on Tutorial guide # 26429 2019-03-04 15:17:21 +01:00
Patrik Nordwall
05d59f8370
Merge pull request #26401 from akka/wip-26305-ccompat-Sink.collection-patriknw 
remove ccompat import in CollectionSinkSpec, #26305
 2019-03-04 15:02:58 +01:00
Arnout Engelen
f2c2e1fa54
Document snapshot releases (#26437) 2019-03-04 14:18:40 +01:00
Patrik Nordwall
0f45eec439 Use AsyncDnsCache directly in DnsServiceDiscovery, #25948 
* to avoid (2) asks
 2019-03-04 13:46:11 +01:00
Johan Andrén
c130a7a609
Merge pull request #26440 from sivapalan/apimaychange-issue-reference-field 
Add issue reference field to ApiMayChange annotation (#26409)
 2019-03-04 13:33:17 +01:00
Arnout Engelen
158b1f6713
Merge pull request #26450 from helena/minor-persistence-wrap 
Fixing minor wrapping.
 2019-03-04 09:16:58 +01:00
Helena Edelson
7e31974192 Fixing minor wrapping. 2019-03-01 10:27:48 -08:00
Johan Andrén
26b0869318
(Prefer) non symbolic typed ask 26306 2019-03-01 15:06:50 +01:00
Arnout Engelen
8853175111 Don't apply 'discipline' flags to compilation run for documentation #26119 
* Avoid -Ywarn-unused:_ on Scala 2.13
* Exclude warn-unused:explicits when generating docs
* Don't apply discipline to the docs compilation run

This approach also means no explicit code is needed anymore to
prevent #26119 from being triggered.
 2019-03-01 13:39:08 +01:00
Martynas Mickevičius
41efdcecfb
Use cross build prefix for every command 2019-03-01 14:29:50 +02:00
Johan Andrén
3a6040ff64 More tweaking the build to make it work 2019-03-01 10:31:29 +01:00
zhongl
1c5c7be8ea Fix typos of OutgoingConnectionStage's port names. 2019-03-01 15:23:28 +08:00
sivapalan
1991e0d23d Format ApiMayChange 2019-02-28 23:52:31 +01:00
Johan Andrén
dc882ee077 Make it compile on 2.13-M5 2019-02-28 16:51:51 +01:00
Arnout Engelen
ef8414d253
Merge pull request #26417 from chbatey/jabba-latest-version 
Use latest java 8 and automatically upgrade in future
 2019-02-27 12:13:52 +01:00
Helena Edelson
3070a84d64
Add html reports for Scoverage (#26444) 2019-02-26 11:54:03 -08:00
Christopher Batey
51add23b2a Cleanup various warnings in akka-stream #26395 2019-02-26 18:28:29 +01:00
Arnout Engelen
c3806c9135
Merge pull request #26380 from chbatey/fix-release-script 
Fix excludes for docs publish in release script
 2019-02-26 12:30:14 +01:00
sivapalan
7642d31c08 Filter out binary incompatibility problem for akka.annotation.ApiMayChange.issue 2019-02-25 22:42:21 +01:00
sivapalan
88c401bf0f Add issue reference field to ApiMayChange annotation (#26409) 2019-02-25 20:15:10 +01:00
Helena Edelson
3f12d35694
Add more code discipline to the build #26376 
* Initial addition of adding more code discipline to the build #26206
* Add Scoverage to the build #25075, jenkins nightly job is set up.

Following up with https://github.com/akka/akka/issues/26389
 2019-02-25 10:23:36 -08:00
Johan Andrén
be7790c7b9 No cross-scala-versions for root 2019-02-25 17:28:26 +01:00
Hungai Amuhinda
7e24f0979e Doc changes (#26430) 2019-02-22 15:08:38 +01:00
Patrik Nordwall
36fe0a0375
Support mutable state by stashing commands while storing snapshot, #25740 2019-02-22 09:00:56 +01:00
Patrik Nordwall
845475b43f
Warn if serializers for Akka internal messages are replaced, #26373 2019-02-22 08:59:17 +01:00
Christopher Batey
15369e4470 Increase timeout for AsyncDnsResovlerSpec + dont use ImplicitSender (#26414) 
* Increase timeout for AsyncDnsResovlerSpec + dont use ImplicitSender

First failure was an optimistic timeout setting then as we
used ImplicitSender the rest of the tests failed due to
unexpected message

* Formatting

* Increase timeout to 300ms
 2019-02-21 20:29:42 +01:00
Luc Bourlier
4ee1ae09a5 Adds Flow.asFlowWithContext 2019-02-21 18:52:01 +01:00
Christopher Batey
b572f541e5 Harden PrimitiveStateSpec: Expect termination before starting next actor #25958 2019-02-21 17:06:56 +01:00
Christopher Batey
111cbc28e9 Make the OO example use classes for all the behaviors (#26407) 
Where as it is valid that stateless actors don't benifit I see
java users using the for everything.:wq
 2019-02-21 16:49:22 +01:00
Patrik Nordwall
cd52f05d3c release flag 11 instead of 9, #26381 
Otherwise there are compilation errors for the
CompileJdk9 sources in some environments
 2019-02-21 16:46:29 +01:00