@Override
    protected void subscribe0(EventExecutor executor, SubscriptionOption[] options) {
        publisher.subscribe(subscriber, executor, options);
    }
Returns a new {@link DecodedStreamMessage} with the specified {@link HttpDecoder},
{@link ByteBufAllocator} and {@code byteBufConverter}.
core/src/main/java/com/linecorp/armeria/internal/common/stream/DecodedStreamMessage.java