public static ByteBufFlux fromString(Publisher<? extends String> source) {
		return fromString(source, Charset.defaultCharset(), ByteBufAllocator.DEFAULT);
	}
@Test
	void testFromString_Flux() {
		List<String> original = Arrays.asList("1", "2", "3");
		StepVerifier.create(ByteBufFlux.fromString(Flux.fromIterable(original)).collectList())
		            .expectNextMatches(list -> {
		                List<String> newList =
		                        list.stream()
		                            .map(b -> {
		                                String result = b.toString(Charset.defaultCharset());
		                                b.release();
		                                return result;
		                            })
		                            .collect(Collectors.toList());
		                return Objects.equals(original, newList);
		            })
		            .expectComplete()
		            .verify(Duration.ofSeconds(30));
	}