List of byteBuffer() Examples

Examples of byteBuffer()

reactor.io.Buffer.byteBuffer()
Return the underlying {@link ByteBuffer}. @return The {@link ByteBuffer} in use.

Examples of reactor.io.Buffer.byteBuffer()


  @SuppressWarnings("unchecked")
  @Override
  protected void write(Object data, Promise<Void> onComplete, boolean flush) {
    Buffer buff = getEncoder().apply((OUT) data);
    write(buff.byteBuffer(), onComplete, flush);
  }


  @Override
  protected synchronized void flush() {
    doFlush(null);

View Full Code Here

Examples of reactor.io.Buffer.byteBuffer()

        } else if(lengthFieldLength == 8) {
          bb = ByteBuffer.allocate(len + 8);
          bb.putLong((long)len);
        }
        if(null != bb) {
          bb.put(encoded.byteBuffer()).flip();
          return new Buffer(bb);
        }
      }
      return encoded;
    }

View Full Code Here

Examples of reactor.io.Buffer.byteBuffer()

      Buffer buff = codec.encoder().apply(t);


      int len = buff.remaining();
      exAppender.startExcerpt(4 + len);
      exAppender.writeInt(len);
      exAppender.write(buff.byteBuffer());
      exAppender.finish();


      size.incrementAndGet();
      lastId.set(exAppender.lastWrittenIndex());
    }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.