This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a change to branch fix/3255-tcp-halfclose-npe
in repository https://gitbox.apache.org/repos/asf/pekko.git
discard 784c1c9856 fix: avoid NPE in outbound TCP stage when upstream finishes
before connect
add 9e5b807897 Update junit-jupiter-engine to 6.1.1 (#3260)
add 0874a04892 Update junit-platform-launcher to 6.1.1 (#3261)
add c0e9406bfd fix: expand Array arguments in MarkerLoggingAdapter log
templates (#3263)
add 64e26c8e51 docs: Clarify retry attempts parameter (#3266)
add cfaec70e81 fix: replace broken scalafmt-native-action with
coursier/setup-action (#3269)
add 84aa2b20e4 fix: add supervision strategy support for expand and
extrapolate (#3185)
add cf6784b952 fix: return proper thread-safe Cancellable from
StubbedActorContext.scheduleOnce (#3268)
add 26d8b60f19 feat(stream): add alsoTo overload with configurable
cancellation propagation (#3127)
add 6287b9de07 Include exception type in StatusReply toString when not
text (#3271)
add 5d1b67dedf docs: document preMaterialize error-propagation caveat
(#3272)
add b9bd7d0f5a feat: add FilteredPayload placeholder for filtered journal
events (#3275)
add 05b300dafb Port scalable fan-out persistence query abstraction from
Akka (#3277)
add 26c5086c7c docs: how to write a custom Durable State store plugin
(#3274)
add e99a741cbc fix: avoid NPE in outbound TCP stage when upstream finishes
before connect
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (784c1c9856)
\
N -- N -- N refs/heads/fix/3255-tcp-halfclose-npe (e99a741cbc)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/format.yml | 9 +-
.../typed/internal/StubbedActorContext.scala | 7 +-
.../testkit/typed/javadsl/BehaviorTestKitTest.java | 38 +
.../typed/scaladsl/BehaviorTestKitSpec.scala | 30 +
.../org/apache/pekko/pattern/PatternsTest.java | 22 +
.../org/apache/pekko/event/MarkerLoggingSpec.scala | 18 +
.../scala/org/apache/pekko/pattern/RetrySpec.scala | 37 +-
.../org/apache/pekko/pattern/StatusReplySpec.scala | 4 +
.../scala/org/apache/pekko/event/Logging.scala | 9 +-
.../scala/org/apache/pekko/pattern/Patterns.scala | 38 +-
.../org/apache/pekko/pattern/RetrySupport.scala | 24 +-
.../org/apache/pekko/pattern/StatusReply.scala | 6 +-
.../docs/persistence/state/MyJavaStateStore.java | 77 ++
.../state/MyJavaStateStoreProvider.java | 45 ++
.../paradox/durable-state/state-store-plugin.md | 45 ++
docs/src/main/paradox/futures.md | 2 +-
docs/src/main/paradox/persistence-query.md | 4 +-
.../stream/operators/Sink/preMaterialize.md | 3 +
.../stream/operators/Source-or-Flow/alsoTo.md | 11 +-
.../stream/operators/Source-or-Flow/expand.md | 8 +-
.../stream/operators/Source-or-Flow/extrapolate.md | 6 +
.../operators/Source-or-Flow/preMaterialize.md | 4 +
.../typed/index-persistence-durable-state.md | 1 +
.../docs/persistence/state/MyStateStore.scala | 71 ++
.../src/test/scala/docs/future/FutureDocSpec.scala | 2 +-
.../state/PersistenceStatePluginDocSpec.scala | 83 ++
.../src/main/resources/reference.conf | 53 ++
.../persistence/query/typed/EventEnvelope.scala | 18 +-
.../EventsBySliceFirehoseReadJournalProvider.scala | 33 +
.../typed/internal/EventsBySliceFirehose.scala | 839 +++++++++++++++++++++
...ByPersistenceIdStartingFromSnapshotQuery.scala} | 16 +-
...tEventsBySliceStartingFromSnapshotsQuery.scala} | 20 +-
...ByPersistenceIdStartingFromSnapshotQuery.scala} | 16 +-
.../typed/javadsl/EventsBySliceFirehoseQuery.scala | 95 +++
.../query/typed/javadsl/EventsBySliceQuery.scala | 2 +
... EventsBySliceStartingFromSnapshotsQuery.scala} | 22 +-
...ByPersistenceIdStartingFromSnapshotQuery.scala} | 16 +-
...tEventsBySliceStartingFromSnapshotsQuery.scala} | 20 +-
...ByPersistenceIdStartingFromSnapshotQuery.scala} | 16 +-
.../scaladsl/EventsBySliceFirehoseQuery.scala | 119 +++
.../query/typed/scaladsl/EventsBySliceQuery.scala | 2 +
... EventsBySliceStartingFromSnapshotsQuery.scala} | 22 +-
.../apache/pekko/persistence/query/TestClock.scala | 59 ++
.../query/typed/EventEnvelopeSpec.scala | 53 ++
.../typed/internal/EventsBySliceFirehoseSpec.scala | 440 +++++++++++
persistence/src/main/resources/reference.conf | 3 +
.../apache/pekko/persistence/FilteredPayload.scala | 26 +
.../serialization/FilteredPayloadSerializer.scala | 45 ++
.../state/DurableStateStoreProvider.scala | 2 +-
.../FilteredPayloadSerializerSpec.scala | 35 +
project/Dependencies.scala | 2 +-
project/StreamOperatorsIndexGenerator.scala | 1 +
.../org/apache/pekko/stream/javadsl/FlowTest.java | 10 +
.../apache/pekko/stream/javadsl/GraphDslTest.java | 22 +
.../apache/pekko/stream/javadsl/SourceTest.java | 10 +
.../apache/pekko/stream/DslConsistencySpec.scala | 1 +
.../pekko/stream/scaladsl/FlowAlsoToSpec.scala | 288 +++++++
.../pekko/stream/scaladsl/FlowExpandSpec.scala | 197 +++++
.../stream/scaladsl/FlowExtrapolateSpec.scala | 108 +++
.../pekko/stream/scaladsl/GraphBroadcastSpec.scala | 45 ++
.../org/apache/pekko/stream/impl/fusing/Ops.scala | 118 ++-
.../org/apache/pekko/stream/javadsl/Flow.scala | 86 ++-
.../org/apache/pekko/stream/javadsl/Graph.scala | 21 +
.../org/apache/pekko/stream/javadsl/Sink.scala | 6 +
.../org/apache/pekko/stream/javadsl/Source.scala | 84 ++-
.../org/apache/pekko/stream/javadsl/SubFlow.scala | 61 +-
.../apache/pekko/stream/javadsl/SubSource.scala | 61 +-
.../org/apache/pekko/stream/scaladsl/Flow.scala | 85 ++-
.../pekko/stream/scaladsl/FlowWithContext.scala | 4 +
.../pekko/stream/scaladsl/FlowWithContextOps.scala | 8 +
.../org/apache/pekko/stream/scaladsl/Graph.scala | 61 +-
.../org/apache/pekko/stream/scaladsl/Sink.scala | 3 +
.../org/apache/pekko/stream/scaladsl/Source.scala | 3 +
.../pekko/stream/scaladsl/SourceWithContext.scala | 4 +
74 files changed, 3659 insertions(+), 206 deletions(-)
create mode 100644
docs/src/main/java/docs/persistence/state/MyJavaStateStore.java
create mode 100644
docs/src/main/java/docs/persistence/state/MyJavaStateStoreProvider.java
create mode 100644 docs/src/main/paradox/durable-state/state-store-plugin.md
create mode 100644
docs/src/main/scala/docs/persistence/state/MyStateStore.scala
create mode 100644
docs/src/test/scala/docs/persistence/state/PersistenceStatePluginDocSpec.scala
create mode 100644
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/EventsBySliceFirehoseReadJournalProvider.scala
create mode 100644
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/internal/EventsBySliceFirehose.scala
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/{CurrentEventsByPersistenceIdTypedQuery.scala
=> CurrentEventsByPersistenceIdStartingFromSnapshotQuery.scala} (58%)
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/{CurrentEventsBySliceQuery.scala
=> CurrentEventsBySliceStartingFromSnapshotsQuery.scala} (51%)
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/{CurrentEventsByPersistenceIdTypedQuery.scala
=> EventsByPersistenceIdStartingFromSnapshotQuery.scala} (58%)
create mode 100644
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/EventsBySliceFirehoseQuery.scala
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/{CurrentEventsBySliceQuery.scala
=> EventsBySliceStartingFromSnapshotsQuery.scala} (53%)
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/{CurrentEventsByPersistenceIdTypedQuery.scala
=> CurrentEventsByPersistenceIdStartingFromSnapshotQuery.scala} (58%)
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/{CurrentEventsBySliceQuery.scala
=> CurrentEventsBySliceStartingFromSnapshotsQuery.scala} (52%)
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/{CurrentEventsByPersistenceIdTypedQuery.scala
=> EventsByPersistenceIdStartingFromSnapshotQuery.scala} (58%)
create mode 100644
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/EventsBySliceFirehoseQuery.scala
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/{CurrentEventsBySliceQuery.scala
=> EventsBySliceStartingFromSnapshotsQuery.scala} (53%)
create mode 100644
persistence-query/src/test/scala/org/apache/pekko/persistence/query/TestClock.scala
create mode 100644
persistence-query/src/test/scala/org/apache/pekko/persistence/query/typed/EventEnvelopeSpec.scala
create mode 100644
persistence-query/src/test/scala/org/apache/pekko/persistence/query/typed/internal/EventsBySliceFirehoseSpec.scala
create mode 100644
persistence/src/main/scala/org/apache/pekko/persistence/FilteredPayload.scala
create mode 100644
persistence/src/main/scala/org/apache/pekko/persistence/serialization/FilteredPayloadSerializer.scala
create mode 100644
persistence/src/test/scala/org/apache/pekko/persistence/serialization/FilteredPayloadSerializerSpec.scala
create mode 100644
stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowAlsoToSpec.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
