This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a change to branch feat/alsoTo-propagateCancellation-3104
in repository https://gitbox.apache.org/repos/asf/pekko.git
omit 6c3c249377 style: apply javafmt to Java test files
omit 6e59fb665f refactor(stream): implement
alsoTo(propagateCancellation=false) via Broadcast
omit fde1950076 fix(stream): correct @since version, add Java tests, clean
up DefaultAttributes
omit 326d4d64cf feat(stream): add alsoTo overload with configurable
cancellation propagation
add f571b64f78 refactor: use RandomGenerator interface instead of
java.util.Random (#3153)
add e1e2f2a4b1 refactor: use ProcessHandle.current().pid() instead of
RuntimeMXBean hack (#3152)
add f60702a4de refactor: replace manual stream copy loops with
transferTo/readAllBytes (#3146)
add fe5771080c refactor: use String.formatted() instead of String.format()
(#3144)
add 6628442f16 fix: remove redundant Float cast in CountMinSketch pattern
match (#3142)
add 71588172e8 refactor: use StackWalker for stack trace inspection in
TestKitUtils (#3141)
add 52755c47c0 refactor: use ByteBuffer fluent API chains with JDK 9
covariant returns (#3139)
add 3ac83fbd31 fix(stream): prevent double materialization of SourceRef
and SinkRef with clear error (#3114)
add 58a9bf0077 perf: use Arrays.copyOf/copyOfRange instead of manual new
Array + arraycopy (#3150)
add 6ad445271c refactor: use StandardCharsets.UTF_8 with
URLEncoder/URLDecoder (#3147)
add 0bbdbf78ec refactor: simplify Collections.unmodifiableSet(emptySet())
to Set.of() (#3138)
add acd4926ac1 refactor: use CompletableFuture.orTimeout in
FutureTimeoutSupport (#3137)
add b7ba750296 refactor: replace sun.reflect.Reflection with StackWalker
in Reflect (#3151)
add 22d44aa429 refactor: use Files.readString() in PemManagersProvider
(#3143)
add 88320c6978 refactor: use HexFormat for hex encoding instead of manual
formatting (#3145)
add 713ad01e16 perf: add Thread.onSpinWait() to CAS spin loops (#3149)
add d957aa9887 docs: update Scaladoc examples from Arrays.asList to
List.of (#3140)
add cd980eac30 use decodeString(StandardCharsets.UTF_8) (#3155)
add 302f1eab04 feat(stream): add alsoTo overload with configurable
cancellation propagation
add 28a7da057f fix(stream): correct @since version, add Java tests, clean
up DefaultAttributes
add 3664e34afd refactor(stream): implement
alsoTo(propagateCancellation=false) via Broadcast
add 49c88779c1 style: apply javafmt to Java test files
add ed64b1efa8 fix(stream): preserve Broadcast binary compatibility and
tighten require
add 93b2b18cb1 style: apply scalafmt to GraphBroadcastSpec
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 (6c3c249377)
\
N -- N -- N refs/heads/feat/alsoTo-propagateCancellation-3104
(93b2b18cb1)
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:
.../scala/org/apache/pekko/util/ReflectSpec.scala | 28 ++++++++
.../io/UnsynchronizedByteArrayInputStream.java | 2 +-
.../apache/pekko/dispatch/AbstractDispatcher.scala | 30 ++++----
.../scala/org/apache/pekko/dispatch/Mailbox.scala | 80 ++++++++++++++--------
.../scala/org/apache/pekko/io/TcpConnection.scala | 4 +-
.../scala/org/apache/pekko/io/UdpConnection.scala | 5 +-
.../scala/org/apache/pekko/io/UdpListener.scala | 5 +-
.../org/apache/pekko/io/dns/IdGenerator.scala | 6 +-
.../org/apache/pekko/pattern/AskSupport.scala | 7 +-
.../pekko/pattern/FutureTimeoutSupport.scala | 28 ++++----
.../scala/org/apache/pekko/util/ByteString.scala | 9 +--
.../main/scala/org/apache/pekko/util/Reflect.scala | 11 +--
.../metrics/protobuf/MessageSerializer.scala | 12 +---
.../typed/internal/ClusterShardingImpl.scala | 7 +-
.../pekko/cluster/sharding/ClusterSharding.scala | 14 ++--
.../org/apache/pekko/cluster/sharding/Shard.scala | 3 +-
.../pekko/cluster/sharding/ShardRegion.scala | 3 +-
.../ClusterShardingMessageSerializer.scala | 12 +---
.../pekko/cluster/client/ClusterClient.scala | 3 +-
.../cluster/pubsub/DistributedPubSubMediator.scala | 5 +-
.../DistributedPubSubMessageSerializer.scala | 12 +---
.../org/apache/pekko/cluster/VectorClock.scala | 6 +-
.../protobuf/ClusterMessageSerializer.scala | 12 +---
.../ddata/protobuf/SerializationSupport.scala | 12 +---
docs/src/test/java/jdocs/io/JavaUdpMulticast.java | 3 +-
.../src/test/scala/docs/io/ScalaUdpMulticast.scala | 3 +-
.../pekko/remote/testkit/PerfFlamesSupport.scala | 4 +-
.../leveldb/scaladsl/LeveldbReadJournal.scala | 6 +-
.../serialization/SnapshotSerializer.scala | 3 +-
.../pekko/persistence/serialization/package.scala | 19 +----
.../snapshot/local/LocalSnapshotStore.scala | 6 +-
.../pekko/remote/artery/aeron/AeronErrorLog.java | 12 ++--
.../remote/artery/compress/CountMinSketch.java | 2 +-
.../scala/org/apache/pekko/remote/Remoting.scala | 4 +-
.../pekko/remote/artery/ImmutableLongMap.scala | 3 +-
.../pekko/remote/artery/tcp/TcpFraming.scala | 2 +-
.../artery/tcp/ssl/PemManagersProvider.scala | 3 +-
.../serialization/jackson/JacksonSerializer.scala | 11 +--
.../serialization/jackson3/JacksonSerializer.scala | 11 +--
.../pekko/stream/scaladsl/GraphBroadcastSpec.scala | 45 ++++++++++++
.../pekko/stream/scaladsl/StreamRefsSpec.scala | 63 ++++++++++++++---
.../scala/org/apache/pekko/stream/Attributes.scala | 4 +-
.../pekko/stream/impl/fusing/StreamOfStreams.scala | 2 +-
.../pekko/stream/impl/io/TlsEngineHelpers.scala | 3 +-
.../pekko/stream/impl/streamref/SinkRefImpl.scala | 18 ++++-
.../stream/impl/streamref/SourceRefImpl.scala | 18 ++++-
.../org/apache/pekko/stream/javadsl/Flow.scala | 8 +--
.../org/apache/pekko/stream/javadsl/Graph.scala | 2 +-
.../org/apache/pekko/stream/javadsl/Source.scala | 8 +--
.../org/apache/pekko/stream/javadsl/SubFlow.scala | 4 +-
.../apache/pekko/stream/javadsl/SubSource.scala | 6 +-
.../org/apache/pekko/stream/scaladsl/Graph.scala | 45 ++++++++++--
.../org/apache/pekko/testkit/TestKitUtils.scala | 10 ++-
53 files changed, 383 insertions(+), 261 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
