io.netty.buffer.Unpooled#wrappedUnmodifiableBuffer ( )源码实例Demo

/**
 * Collect all the data from the given contents into a {@link ByteBuf}.
 */
private ByteBuf toByteBuf(List<BufferView> contents) {
    val buffers = contents.stream()
            .flatMap(bv -> bv.getContents().stream())
            .map(Unpooled::wrappedBuffer)
            .toArray(ByteBuf[]::new);
    return Unpooled.wrappedUnmodifiableBuffer(buffers);
}
 

private ByteBuf toByteBuf(BufferView bufferView) {
    if (bufferView.getLength() == 0) {
        return EMPTY_BUFFER;
    }

    val buffers = bufferView.getContents().stream().map(Unpooled::wrappedBuffer).toArray(ByteBuf[]::new);
    return Unpooled.wrappedUnmodifiableBuffer(buffers);
}
 

public ByteBuf getAsByteBuf() {
    ByteBuf header = Unpooled.buffer(TYPE_PLUS_LENGTH_SIZE, TYPE_PLUS_LENGTH_SIZE);
    header.writeInt(type.getCode());
    header.writeInt(data.readableBytes());
    return Unpooled.wrappedUnmodifiableBuffer(header, data);
}
 

private ByteBuf toByteBuf(BufferView bufferView) {
    val buffers = bufferView.getContents().stream().map(Unpooled::wrappedBuffer).toArray(ByteBuf[]::new);
    return Unpooled.wrappedUnmodifiableBuffer(buffers);
}
 

private ByteBuf convertData(CompositeArrayView data) {
    ByteBuf[] components = new ByteBuf[data.getComponentCount()];
    val index = new AtomicInteger();
    data.collect(bb -> components[index.getAndIncrement()] = Unpooled.wrappedBuffer(bb));
    return Unpooled.wrappedUnmodifiableBuffer(components);
}