reactor-netty-core/src/main/java/reactor/netty/NettyOutbound.java
/**
	 * Sends data to the peer, listens for any error on write and closes on terminal signal
	 * (complete|error). Each individual {@link Publisher} completion will flush
	 * the underlying IO runtime.
	 * <p>Note: Nesting any send* method is not supported.</p>
	 *
	 * @param dataStreams the dataStream publishing OUT items to write on this channel
	 *
	 * @return A {@link Mono} to signal successful sequence write (e.g. after "flush") or
	 * any error during write
	 */
Sends data to the peer, listens for any error on write and closes on terminal signal
(complete|error). Each individual  Publisher completion will flush
the underlying IO runtime.
Note: Nesting any send* method is not supported.

@param dataStreams the dataStream publishing OUT items to write on this channel

@return A  Mono to signal successful sequence write  or
any error during write
Sends data to the peer listens for any error on write and closes on terminal signal ( complete|error ) . Each individual Publisher completion will flush the underlying IO runtime . Note : Nesting any send * method is not supported . @param dataStreams the dataStream publishing OUT items to write on this channel @return A Mono to signal successful sequence write or any error during write
default NettyOutbound sendGroups(Publisher<? extends Publisher<? extends ByteBuf>> dataStreams) {
		return send(
				Flux.from(dataStreams)
				    .concatMap(p -> Flux.<ByteBuf>from(p)
				                        .concatWith(Mono.just(ReactorNetty.BOUNDARY)), 32),
				ReactorNetty.PREDICATE_GROUP_FLUSH);
	}
default NettyOutbound sendGroups ( Publisher < ? extends Publisher < ? extends ByteBuf > > dataStreams ) { return send ( Flux . from ( dataStreams ) . concatMap ( p -> Flux . < ByteBuf > from ( p ) . concatWith ( Mono . just ( ReactorNetty . BOUNDARY ) ) , 32 ) , ReactorNetty . PREDICATE_GROUP_FLUSH ) ; }
Sends data to the peer, listens for any error on write and closes on terminal signal
 (complete|error).
Sends data to the peer listens for any error on write and closes on terminal signal ( complete|error ) .