It might be helpful to provide a public static method to create a failed body subscriber. The failed body subscriber would:
- return a failed completion stage in getBody()
- cancel its subscription in onSubscribe()

Something like:

public static <T> BodySubscriber<T> failedSubscriber(Throwable t);