code: public static ByteBufFlux fromInbound(Publisher<?> source,
  			ByteBufAllocator allocator) {
  		Objects.requireNonNull(allocator, "allocator");
  		return new ByteBufFlux(Flux.from(source)
  		                           .map(bytebufExtractor), allocator);
  	}
docs: Decorate as {@link ByteBufFlux}
  
  @param source publisher to decorate
  @param allocator the channel {@link ByteBufAllocator}
  
  @return a {@link ByteBufFlux}