code: public Flux<InputStream> asInputStream() {
  		return handle((bb, sink) -> {
  			try {
  				sink.next(new ByteBufMono.ReleasingInputStream(bb));
  			}
  			catch (IllegalReferenceCountException e) {
  				sink.complete();
  			}
  		});
  	}
docs: Convert to a {@link InputStream} inbound {@link Flux}
  
  @return a {@link InputStream} inbound {@link Flux}