List view

add non-default config that allows InboundQuarantineCheck to ignore 'harmless' quarantine events

cluster

Status: Merged (completed).

apache/pekkonumber 1555

#1555 In apache/pekko;

· by pjfanning was closed on Jan 4, 2025

Make flatMapPrefix javadsl using java.util.List

questionFurther information is requestedFurther information is requested

t:streamPekko StreamsPekko Streams

Status: Merged (completed).

apache/pekkonumber 271

#271 In apache/pekko;

· by He-Pin was closed on Jan 4, 2025

Update scala-library to 2.13.15

Status: Merged (completed).

apache/pekkonumber 1505

#1505 In apache/pekko;

· by scala-steward-asf was closed on Jan 3, 2025

Add overridden duration timeout to StreamTestKit

t:streamPekko StreamsPekko Streams

Status: Merged (completed).

apache/pekkonumber 1468

#1468 In apache/pekko;

· by mdedetrich was closed on Jan 25, 2025

jackson 2.18 with max-token-count support

release notesNeed to release noteNeed to release note

Status: Merged (completed).

apache/pekkonumber 1556

#1556 In apache/pekko;

· by pjfanning was closed on Dec 28, 2024

chore: Enable netty leak detector in CI

buildsbt or build of the projectsbt or build of the project

Status: Merged (completed).

apache/pekkonumber 1639

#1639 In apache/pekko;

· by He-Pin was closed on Dec 28, 2024

chore: Add netty leak detector in multi-node-testing.

buildsbt or build of the projectsbt or build of the project

Status: Merged (completed).

apache/pekkonumber 1641

#1641 In apache/pekko;

· by He-Pin was closed on Dec 29, 2024

chore: Fix the @since of Sink.none operator, should be 1.2.0

t:streamPekko StreamsPekko Streams

Status: Merged (completed).

apache/pekkonumber 1632

#1632 In apache/pekko;

· by He-Pin was closed on Dec 28, 2024

chore: Turn on Netty's leak detector in build.

buildsbt or build of the projectsbt or build of the project

Status: Merged (completed).

apache/pekkonumber 1637

#1637 In apache/pekko;

· by He-Pin was closed on Dec 28, 2024

perf: Reduce loops when cleaning queue in BroadcastHub

t:streamPekko StreamsPekko Streams

Status: Merged (completed).

apache/pekkonumber 1628

#1628 In apache/pekko;

· by He-Pin was closed on Dec 30, 2024

fix: avoid call finalizeStage more times than once.

backport

bugSomething isn't workingSomething isn't working

t:streamPekko StreamsPekko Streams

Status: Merged (completed).

apache/pekkonumber 1650

#1650 In apache/pekko;

· by He-Pin was closed on Dec 31, 2024

fix: avoid boxing in zipWithIndex and fix type signature in SubSource#zipWithIndex

t:streamPekko StreamsPekko Streams

Status: Merged (completed).

apache/pekkonumber 1669

#1669 In apache/pekko;

· by He-Pin was closed on Jan 7, 2025

perf: optimize NettyChannelHandlerAdapter with explict extends.

performanceRelated to performanceRelated to performance

Status: Merged (completed).

apache/pekkonumber 1667

#1667 In apache/pekko;

· by He-Pin was closed on Jan 3, 2025

fix: Fix occasional ordering issue in FlowWithContext#unsafeOptionalDataVia

backport

bugSomething isn't workingSomething isn't working

t:streamPekko StreamsPekko Streams

Status: Merged (completed).

apache/pekkonumber 1681

#1681 In apache/pekko;

· by He-Pin was closed on Jan 5, 2025

chore: Test more rounds for unsafeDataVia keeping order.

backport

t:streamPekko StreamsPekko Streams

Status: Merged (completed).

apache/pekkonumber 1680

#1680 In apache/pekko;

· by He-Pin was closed on Jan 5, 2025

chore: Use more lambda style in stream module.

Status: Merged (completed).

apache/pekkonumber 1686

#1686 In apache/pekko;

· by He-Pin was closed on Jan 6, 2025

chore: Avoid forwarding method on ArrayDequeue in stream module.

t:streamPekko StreamsPekko Streams

Status: Merged (completed).

apache/pekkonumber 1687

#1687 In apache/pekko;

· by He-Pin was closed on Jan 6, 2025

feat: Add Sink.none operator

t:streamPekko StreamsPekko Streams

Status: Merged (completed).

apache/pekkonumber 1614

#1614 In apache/pekko;

· by He-Pin was closed on Dec 28, 2024

chore: avoid create an empty array everytime.

t:streamPekko StreamsPekko Streams

Status: Merged (completed).

apache/pekkonumber 1616

#1616 In apache/pekko;

· by He-Pin was closed on Dec 28, 2024

fix: Fix a leak in PrefixAndTail operator.

bugSomething isn't workingSomething isn't working

t:streamPekko StreamsPekko Streams

Status: Merged (completed).

apache/pekkonumber 1623

#1623 In apache/pekko;

· by He-Pin was closed on Jan 3, 2025

fix: Fix leak in FlatMapPrefix operator.

bugSomething isn't workingSomething isn't working

t:streamPekko StreamsPekko Streams

Status: Merged (completed).

apache/pekkonumber 1622

#1622 In apache/pekko;

· by He-Pin was closed on Jan 3, 2025

chore: fix failed in StreamConvertersSpec

backport

t:streamPekko StreamsPekko Streams

Status: Merged (completed).

apache/pekkonumber 1655

#1655 In apache/pekko;

· by He-Pin was closed on Dec 31, 2024

chore: Add identity function.

t:streamPekko StreamsPekko Streams

Status: Merged (completed).

apache/pekkonumber 1671

#1671 In apache/pekko;

· by He-Pin was closed on Jan 6, 2025

chore: Avoid forwarding method on ArrayDequeue in BatchingExecutor.

Status: Merged (completed).

apache/pekkonumber 1688

#1688 In apache/pekko;

· by He-Pin was closed on Jan 6, 2025

chore: bump Scala to 2.13.16

Status: Merged (completed).

apache/pekkonumber 1704

#1704 In apache/pekko;

· by He-Pin was closed on Jan 10, 2025