@Test
    void notifyCancellation() {
        final ByteBuf buf = newPooledBuffer();
        final StreamWriter<HttpData> delegate = StreamMessage.streaming();
        delegate.write(HttpData.wrap(buf));
        final PublisherBasedStreamMessage<HttpData> p = new PublisherBasedStreamMessage<>(delegate);
        SubscriptionOptionTest.notifyCancellation(buf, p);
    }
Tests if {@link PublisherBasedStreamMessage#abort()} prohibits further subscription.
core/src/test/java/com/linecorp/armeria/common/stream/PublisherBasedStreamMessageTest.java