Apache Pekko 1.1.0‐M1

Draft Release notes for Apache Pekko 1.1.0-M1. See Milestone for fuller list of changes.

1.0.x changes

Apache Pekko 1.1.0-M1 contains all the changes that have been released in the 1.0.x patches, with the exception of the changes to support interacting with Akka remote and cluster instances (PR765, PR1112).

Bug Fixes

• in TlsActor, flush data to user only after handshake has finished (PR1128)

Additional APIs

• Add asInputStream to ByteString (PR1085)

The Stream API has been updated to add some extra functions.

• add collectFirst stream operator (PR984)
• add collectWhile stream operator (PR957)
• add dimap stream operator (PR942)
• add flatten stream operator (PR937)
• add flattenMerge stream operator (PR945)
• add foldWhile stream operator (PR1012)
• add mapAsyncPartitioned / mapAsyncPartitionedUnordered stream operators (PR561)
• add mapWithResource stream operator (PR931, PR1053)
• add onErrorComplete stream operator (PR913)
• add support for for comprehensions (PR935)
• add Sink.exists operator (PR990)
• add Sink.forall operator (PR989)

[Add More Details]

Removed

• The pekko-protobuf jar is no longer published. The pekko-protobuf-v3 jar is still published (PR489)

Other Changes

• Scala 2 inline optimizer has been enabled
• Classic Remoting was updated to use Netty 4 instead of Netty 3 (PR643)
• Support configuration for Jackson Recycler Pool (PR1192)
• pekko-multi-node-testkit was changed to use Netty 4 instead of Netty 3 (PR539)
• add junit5 support to pekko-testkit-typed (PR751)
• Some performance changes in the Stream code (PR48, PR49, PR278, PR363, PR408, PR983, PR1027)

Dependency Changes

Most of the dependency changes are small patch level upgrades. Some exceptions include:

• The protobuf-java code that is shaded and released as pekko-protobuf-v3 has been upgraded to protobuf-java 3.25.2
• slf4j was updated to v2 (PR748)
• Jackson 2.16.2