Bryce Anderson
Bryce Anderson
Motivation: Sometimes people just want to get the last failed response when the retry loop ends. However, right now we only yield the exceptions that where created. Users can't do...
https://github.com/apple/servicetalk/actions/runs/14410532770/job/40417131618#step:8:513 ``` Gradle suite > Gradle test > io.servicetalk.concurrent.reactivestreams.tck.PublisherSwitchMapDelayErrorTckTest > required_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber FAILED java.lang.AssertionError: Publisher io.servicetalk.concurrent.reactivestreams.ReactiveStreamsAdapters$StToRsPublisher@2b40ff9c did not drop reference to test subscriber after subscription cancellation at org.testng.Assert.fail(Assert.java:110) at org.reactivestreams.tck.TestEnvironment.flop(TestEnvironment.java:222) at...
Motivation: We have the watchdog based leak detection which is pretty good but can't catch all cases, including when a message body is subscribed to but subsequently orphaned. Modifications: Add...
https://github.com/apple/servicetalk/actions/runs/11849584912/job/33052783755?pr=3107#step:8:882 ``` ConnectionCloseHeaderHandlingTest > PipelinedRequestsTest > serverCloseSecondPipelinedRequestWriteAborted(boolean, boolean, boolean) > 4: useUds=false, viaProxy=true, awaitRequestPayload=true FAILED java.util.concurrent.ExecutionException: io.servicetalk.transport.netty.internal.CloseHandler$CloseEventObservedException: PROTOCOL_CLOSING_INBOUND(The application protocol closed the read side of this connection. This maybe the...
This is an alternative to https://github.com/apple/servicetalk/pull/3368
Exercising https://github.com/netty/netty/pull/15818.