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

25540 commits

This branch
This branch
All branches
Author SHA1 Message Date
Johan Andrén
0d64ac3cd7
Add a note about shard actor factory being local (#29970) 2021-01-28 09:35:23 +00:00
Johan Andrén
6c79c2b60b
Race condition in prefixAndTail around double materialization fixed #29965 (#29976) 2021-01-28 09:34:56 +00:00
Johan Andrén
7d25067568
Update to paradox theme with new cookie banner (#29978) 2021-01-28 09:31:55 +00:00
Michael Marshall
4d9b25579d
Add GroupedWeighted FlowOp and Make Grouped use GroupedWeighted #29066 2021-01-27 18:03:30 +01:00
Jabir S. Minjibir
dffd7099fd
Update event-bus.md (#29979) 2021-01-27 11:24:15 +01:00
Johan Andrén
0bf29fd232
SubSinkInlet/SubSourceOutlet memory leak fix (#29967) 
* Memory leak in auto-closing of sub inlets/outlets fixed #29966
* Avoid separate nested instances of the AsyncCallback state classes for each async callback.
 2021-01-25 15:35:54 +01:00
Renato Cavalcanti
9e97b995f0
Update replicated ES support for JDBC (#29968) 2021-01-25 11:27:12 +01:00
franciscolopezsancho
13cc7e5ef0
broken link (#29974) 2021-01-25 09:39:01 +01:00
Scala Steward
1542ef1e6a
Update asn-one to 0.5.0 (#29943) 2021-01-21 16:35:59 +01:00
Scala Steward
2a698ad53b
Update sbt-pgp to 2.1.1 (#29944) 2021-01-21 16:35:30 +01:00
Patrik Nordwall
4b23d0ccc0
Merge pull request #29958 from johanandren/wip-29949-WorkPullingWithEventSourcedProducerQueueSpec-race-fix 
Race condition in WorkPullingWithEventSourcedProducerQueueSpec
 2021-01-20 10:36:46 +01:00
Johan Andrén
88ac481c68 Fix for race condition in WorkPullingWithEventSourcedProducerQueueSpec #29949 2021-01-19 13:36:40 +01:00
franciscolopezsancho
8e47656b56
Typo (#29954) 2021-01-19 08:43:46 +01:00
kerr
01ad4620ec
Add more comments about formatting. (#29001) 2021-01-18 13:03:22 +01:00
Patrik Nordwall
c83b57674f
update latestPatchOf26 to 2.6.11 (#29952) 2021-01-15 17:13:40 +01:00
Patrik Nordwall
9fce9a9c33
more headers (#29953) 2021-01-15 16:11:00 +01:00
Johan Andrén
ba3af3ea46
Adapted message failure supervision bugfix (#29847) 2021-01-13 20:58:48 +01:00
Patrik Nordwall
feec7aa9b1
Merge pull request #29873 from akka/wip-29854-RequestNext-bug-patriknw 
Fix duplicate RequestNext messages in durable WorkPullingProducerController, #29854
 2021-01-13 17:20:32 +01:00
Patrik Nordwall
ffc356c106
Merge pull request #29926 from johanandren/wip-29904-EventSourcedBehaviorTestKit-serialization-config 
EventSourcedBehaviorTestKit serialization improvements
 2021-01-13 17:10:51 +01:00
Johan Andrén
a34357644f
Incorrect test expectations i FlowFutureFlowSpec fixed (#29899) 2021-01-13 10:15:48 +01:00
Johan Andrén
a1d405d564
Merge pull request #29881 from scala-steward/update/jackson-databind-2.10.5.1 
* Update jackson-databind to 2.10.5.1
* Separately version jackson-databind
 2021-01-13 09:37:52 +01:00
Patrik Nordwall
65fa8b635a
Merge pull request #29945 from scala-steward/update/metrics-core-4.1.16 
Update metrics-core, metrics-jvm to 4.1.16
 2021-01-13 08:07:21 +01:00
Nitika Agarwal
8361b2a1b9
Add example for mapError (#29913) 2021-01-13 08:05:47 +01:00
Nitika Agarwal
294661bde1
Add example for foldAsync (#29912) 2021-01-13 08:01:58 +01:00
Patrik Nordwall
7920694b81
Merge pull request #29867 from johanandren/wip-29858-dns-failure 
Longer DNS timeout to avoiding ci fail
 2021-01-13 07:50:22 +01:00
Adrian
130a200a85
Add askWithStatus Streams operator, #29504 (#29727) 2021-01-13 07:48:59 +01:00
Patrik Nordwall
96548837c6
Merge pull request #29833 from raboof/exhaustive-cachePolicy-comparison 
Exhaustive comparison for cache policies
 2021-01-13 07:47:02 +01:00
Patrik Nordwall
89583aa8cf
Merge pull request #29738 from YikSanChan/add-doc-to-explain-cleanup-impl 
Explain why Mailbox#cleanup uses recursion [ci skip]
 2021-01-13 07:45:26 +01:00
Patrik Nordwall
20ac7278cd
Merge pull request #29861 from ennru/show-bom 
docs: show BOM include in all dependency listings
 2021-01-13 07:38:33 +01:00
Johan Andrén
ccc4a2f48b
Improved operator string represenation #29935 
* New attribute with source location information introduced and added to stages that takes lambdas
* Better default toString for GraphStageLogic including source location where possible
  and used that for debugging, errors and stream snapshots
 2021-01-11 15:17:50 +01:00
eyal farago
b8c79f8695
Akka29924 router pool bcast (#29927) 2021-01-11 15:08:56 +01:00
Patrik Nordwall
2dedb715a1
Merge pull request #29934 from akka/rgc/use-java-predicate 
Use java.util.function.Predicate for Stash Java API
 2021-01-11 14:17:48 +01:00
Levi Ramsey
1fd66f5f49
Make typed TestProbe a RecipientRef (#29928) 2021-01-11 11:53:42 +01:00
franciscolopezsancho
51548f6227
typo (#29941) 2021-01-11 09:11:43 +01:00
Patrik Nordwall
146944f999
Merge pull request #29937 from raboof/copyright-2021 
Update copyright to 2021
 2021-01-11 08:38:48 +01:00
Scala Steward
245ea645a2
Update metrics-core, metrics-jvm to 4.1.16 2021-01-10 02:03:46 +01:00
Arnout Engelen
31f654768f
Update copyright to 2021 2021-01-08 17:55:38 +01:00
Renato Cavalcanti
4132507486
use java Predicate in Java API 2021-01-07 21:10:01 +01:00
Arnout Engelen
9f3d0a9887
tcp: clearer debug message when connection is closed successfully (#29931) 2021-01-07 14:20:23 +01:00
Johan Andrén
e8e62e2ca2
Make sure static mdc from withMdc set during actor startup (#29894) 
* Make sure static mdc from withMdc set during actor startup #29893

* Actually assert mdc is included
 2021-01-04 15:04:14 +01:00
Johan Andrén
c64537c383 Disable snapshot serialization by default, log warning if serialization enabled #29904 2021-01-04 14:56:05 +01:00
Johan Andrén
df4663867d
ScalaFutures timeout is too short MultiDcClusterSharding test (#29917) 2021-01-04 12:56:49 +01:00
Johan Andrén
dfc9d6e20f
No empty state serialization check when not enabled (#29905) 
* Don't verify empty state serialization when state serialization check is not enabled in EventSourcedBehaviorTestKit
 2021-01-04 11:02:42 +01:00
Patrik Nordwall
ec7e1f29f2
Merge pull request #29886 from scala-steward/update/jctools-core-3.2.0 
Update jctools-core to 3.2.0
 2021-01-04 10:58:03 +01:00
Johan Andrén
f932f15095
Missing boundary for expectation to always hold #29777 (#29896) 2021-01-04 09:59:27 +01:00
Patrik Nordwall
f1574844ed
Merge pull request #29914 from johanandren/wip-29735-deprecatedsupervisionspec-fail-fix 
Race condition in DeprecatedSupervisionSpec fixed
 2021-01-04 09:00:14 +01:00
Josep Prat
17d45ec5e9
Change wording on a sentence (#29918) 2020-12-22 14:09:42 +01:00
Nicolas Vollmar
40713f836f
Adds variant accepting any ack message (#29586) (#29910) 2020-12-22 09:46:38 +01:00
eyal farago
f68f0cd805
Akka 29900 stubbed timer (#29903) 
* master: abstract over TimerScheduler

* master: introduce effects for scheduled timer and cancelled timer.

* master: introduce a failing test

* master: introduce an effectfull timer scheduler into the effectfull actor ctx.

* master: scalafmtall

* akka-29900__stubbed_timer: compilation fix.

* akka-29900__stubbed_timer: modify stubbed timer scheduler effects and behaviour to closely mimic the actual timer's contract.

* akka-29900__stubbed_timer: more tests

* akka-29900__stubbed_timer: scalafmtAll

* akka-29900__stubbed_timer: fix a deprecation issue and a failed test.

* akka-29900__stubbed_timer: scalafmtall

* akka-29900__stubbed_timer: remove unused val

* akka-29900__stubbed_timer: remove unused import

* akka-29900__stubbed_timer: fmt

* akka-29900__stubbed_timer: add java API for the new Effect.

* akka-29900__stubbed_timer: unused import

* akka-29900__stubbed_timer: fmt

* akka-29900__stubbed_timer: add explicit return type

* akka-29900__stubbed_timer: scalafmtAll

* akka-29900__stubbed_timer: resolve mima issues

* akka-29900__stubbed_timer: better asJava/asScala support for TimerScheduler

* akka-29900__stubbed_timer: avoid invoking a deprecated method.

* akka-29900__stubbed_timer: remove unuse import

* akka-29900__stubbed_timer: couple more unused imports.

* akka-29900__stubbed_timer: remove TimerScheduler.asJava/Scala se these are not needed. sort out mima related failures.

* akka-29900__stubbed_timer: unused import + DoNotInherit annotation.

* akka-29900__stubbed_timer: modify docs, add the timer related effects.

* akka-29900__stubbed_timer: fmt

* akka-29900__stubbed_timer: unused import

* akka-29900__stubbed_timer: fmt

* akka-29900__stubbed_timer: scala 2.13 compilation quircks

* akka-29900__stubbed_timer: move the mima exclude file

* akka-29900__stubbed_timer: small fixup

* akka-29900__stubbed_timer: fmt
 2020-12-21 14:05:56 +01:00
Johan Andrén
3693b21383 Race condition in DeprecatedSupervisionSpec fixed #29735 2020-12-21 13:12:54 +01:00