@ParameterizedTest
    @ArgumentsSource(AbortCauseArgumentProvider.class)
    void testAbortWithLateOnSubscribe(@Nullable Throwable cause) {
        final AbortTest test = new AbortTest();
        test.prepare();
        test.abort(cause);
        test.invokeOnSubscribe();
        test.awaitAbort(cause);
        test.verify(cause);
    }
Tests if {@link PublisherBasedStreamMessage#abort()} cancels the {@link Subscription} even if
{@link Subscriber#onSubscribe(Subscription)} was invoked by the delegate {@link Publisher} after
{@link PublisherBasedStreamMessage#abort()} is called.
core/src/test/java/com/linecorp/armeria/common/stream/PublisherBasedStreamMessageTest.java