Johan Andrén
031886a7b3
MiMa latest patch update to 2.6.14 ( #30173 )
2021-04-08 14:59:08 +02:00
Andrea Zito
318b9614a3
Add draining control support to MergeHub #30057
...
- MergeHub materialization now produces a DrainingControl object alongside the Sink
- The DrainingControl can be invoked to initiate the draining procedure
- No new producers can be connected to the Hub
- The Hub is completed as soon as all the currently connected producers complete
2021-04-07 11:34:59 +02:00
Christopher Batey
99ec6f9d82
Document persist failure supervision for ESBs #30062
2021-04-07 11:33:08 +02:00
Eugene Apollonsky
71225b4f2b
Avoid TaskQueue allocations in Scheduler #30093
2021-04-06 15:21:11 +02:00
Arman Bilge
f155ff12fa
Remove async boundary note in Source.actorRef docs ( #30162 )
2021-04-06 12:23:02 +02:00
Arman Bilge
40f1edf89f
Preserve attributes of inner stages when using {Source,Flow,Sink}.fromMaterializer ( #30142 )
2021-04-02 16:04:07 +02:00
franciscolopezsancho
fb432b3d8a
Typed consistent hashing example ( #30036 )
...
Co-authored-by: Renato Cavalcanti <renato@cavalcanti.be>
2021-04-01 09:31:42 +02:00
archeuclid
55ec18962c
Change Effects() to Effect() ( #30157 )
2021-04-01 08:55:56 +02:00
Andrei Arlou
6f3ea12282
Remove unnecessary modifiers from FI.java ( #30119 )
2021-04-01 08:00:17 +02:00
Jorge Gomez
914a94e405
ActorSinkWithAckExample Ack message ( #30127 )
...
Using the example does not work in Java, because it seems that `Sink` compares by equality, no by class.
2021-03-31 09:14:12 +02:00
Scala Steward
4ff77b813e
Update junit to 4.13.2 ( #30099 )
2021-03-30 23:29:37 +02:00
Johan Andrén
c5655a9ce6
Upgrade to Scala 2.13.5 ( #30072 )
2021-03-30 20:57:23 +02:00
Andrei Arlou
846359919f
Refactor SourceTest.java: use diamong operator, use assertThrows ( #30152 )
2021-03-30 17:37:19 +02:00
Eugene Apollonsky
03375a7eff
Implement isTimerActive for BehaviorTestKit #30140 ( #30144 )
2021-03-30 16:17:25 +02:00
Andrei Arlou
f7c559e057
Use type inference for collections in FlowTest.java ( #30110 )
2021-03-29 17:34:01 +02:00
Seeta Ramayya
99af826546
Renamed single letter parameter ( #30150 )
...
* Renamed method parameter (`d` -> `duration`) in akka-actor-typed and akka-stream modules #30115
* Renamed method parameter (`n` -> `maxNumber`) and accordingly adjusted inline scala docs
2021-03-29 17:31:39 +02:00
Renato Cavalcanti
7394ce408b
Remove recursive call to Java withBroadcastPredicate ( #30078 )
2021-03-29 11:18:24 +02:00
Patrik Nordwall
aaeb6ec591
Merge pull request #30137 from johanandren/wip-crosslink-coexistance-top-level-spawn
...
Crosslink and extra sentence about top level spawn in from-classic
2021-03-29 10:55:30 +02:00
Patrik Nordwall
1756b2a4cc
Merge pull request #30148 from archeuclid/document-lease-can-be-used-for-sbr
...
Add link to SBR lease documentation; fix minor syntax mistakes
2021-03-29 10:24:59 +02:00
archeuclid
0c218cb406
Add link to SBR lease documentation; fix minor syntax mistakes
2021-03-26 13:14:53 +06:00
Johan Andrén
0326e11387
Unwrap tagged replicated events before publishing to other replicas ( #30136 )
2021-03-25 14:24:34 +01:00
Patrik Nordwall
c14e8e6c44
remove default-dispatcher from heartbeat delay message ( #30109 )
...
* Cluster actors are running on internal dispatcher
2021-03-25 11:14:41 +00:00
Johan Andrén
6789a289d4
Upgrade jackson to 2.11.4 #30126 ( #30130 )
2021-03-22 18:01:31 +01:00
Scala Steward
0a10ce8686
Update sbt-dotty to 0.5.3 ( #30095 )
2021-03-22 11:47:30 +01:00
Alex
651b339777
Added size() to BoundedSourceQueue #30124 ( #30125 )
2021-03-22 11:45:47 +01:00
Johan Andrén
456a2637d9
Crosslink and extra sentence about top level spawn in from-classic #30089
2021-03-19 16:57:31 +01:00
Patrik Nordwall
22fd122f4c
minor corrections of remoting docs ( #30107 )
2021-03-19 11:17:05 +01:00
Andrei Arlou
fbc09c55f7
Replace Charset.forName("UTF-8") on StandartCharsets.UTF_8 ( #30113 )
2021-03-19 11:15:50 +01:00
Arnout Engelen
c737f1a8e6
Commit api/japi docs when releasing ( #30128 )
2021-03-18 15:04:43 +01:00
Arnout Engelen
8eb8396306
genjavadoc: update 0.16 -> 0.17 ( #30121 )
...
To get the fix for 'rangepos', which is becoming the default with 2.13.5
2021-03-17 13:16:47 +01:00
Johan Andrén
5d5a797145
Allow custom mailbox for user guardian ( #30116 )
2021-03-17 10:39:05 +01:00
Andrea Peruffo
73b97871b6
Bump Scala 3 to RC1 ( #30117 )
2021-03-16 17:33:56 +01:00
Levi Ramsey
f3456b382e
Clarify API-docs - desugaring of IncomingConnection.handleWith ( #30025 )
2021-03-15 17:32:35 +01:00
刘冲
c24759feaa
Update ActorHierarchyExperiments.java ( #30075 )
...
Update SupervisedActor example to fit tutorial 1 docs
2021-03-15 15:48:02 +01:00
Arman Bilge
1ff2950ab6
Inherit attributes from Restart{Source,Flow,Sink} #24810
2021-03-15 12:47:37 +01:00
Andrei Arlou
573a97debb
Change parameters order for assertEquals in tests: JavaFutureTests and LeaseProviderTest ( #30094 )
2021-03-15 12:43:33 +01:00
Patrik Nordwall
8006b5245c
Link to Akka Cloud Platform ( #30112 )
2021-03-15 12:42:15 +01:00
Alex
1044c4996e
Extend GroupedWeightedWithin to accept maxWeight and maxNumber simultaneously #30020
2021-03-15 12:38:28 +01:00
Andrei Arlou
23f703fa08
Refactor exception handling in StatusReplyTest ( #30081 )
...
* Refactor exception handling in StatusReplyTest
* Change messages in assertThrows
2021-03-12 11:46:20 +01:00
Patrik Nordwall
d19855542b
configuration for SBR lease release #30090 ( #30092 )
2021-03-11 13:29:20 +01:00
Ignasi Marimon-Clos
8f6ee85413
typo ( #30083 )
2021-03-10 09:10:55 +01:00
Johannes Rudolph
0576acc1da
stream: add assertion against JDK bug to avoid spin loop in TlsActor ( #30043 )
...
* stream: add assertion against JDK bug to avoid spin loop in TlsActor
Refs #29922
2021-03-10 08:49:15 +01:00
Nicolas Vollmar
4081638fd8
Adds initial delay to Timers #30065 ( #30066 )
2021-03-05 08:41:13 +01:00
Johan Andrén
b208265e5c
Add batchable sources also for Scala 3 ( #30069 )
2021-03-01 11:57:47 +01:00
Johan Andrén
cc6d55183f
Use scala.concurrent.Batchable for Scala 2.13 #29980
2021-03-01 10:15:58 +01:00
Scala Steward
e85bc51e82
Update sbt-scalafix to 0.9.25 ( #30012 )
2021-03-01 08:39:55 +00:00
Johan Andrén
3591498cf2
Bump mima latest patch ( #30061 )
2021-02-24 10:38:18 +01:00
Johan Andrén
477dc7f651
Doubly dilated timeouts in typed test probe #30021 ( #30033 )
2021-02-22 17:48:12 +01:00
Patrik Nordwall
5b567b14f4
Merge pull request #30052 from johanandren/wip-copy-snippet-docs
...
Update to sbt-paradox-akka 0.38 with copy-snippet support for the docs
2021-02-22 17:18:51 +01:00
Ignasi Marimon-Clos
ac530913ac
Update manifestInfo docs ( #30056 )
...
* Update snippet. Cross-reference to BOMs
* Update akka-docs/src/main/paradox/common/binary-compatibility-rules.md
Co-authored-by: Johan Andrén <johan@markatta.com>
Co-authored-by: Johan Andrén <johan@markatta.com>
2021-02-22 17:18:10 +01:00