@ParameterizedTest
    @ArgumentsSource(AbortCauseArgumentProvider.class)
    void testAbortWithEarlyOnSubscribe(@Nullable Throwable cause) {
        final AbortTest test = new AbortTest();
        test.prepare();
        test.invokeOnSubscribe();
        test.abortAndAwait(cause);
        test.verify(cause);

        // Try to abort again, which should do nothing.
        test.abortAndAwait(cause);
        test.verify(cause);
    }
Tests if {@link PublisherBasedStreamMessage#abort()} cancels the {@link Subscription}, and tests if
the abort operation is idempotent.
core/src/test/java/com/linecorp/armeria/common/stream/PublisherBasedStreamMessageTest.java