io.vertx.core.buffer.Buffer.appendLong()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(6.0k)|赞(0)|评价(0)|浏览(110)

本文整理了Java中io.vertx.core.buffer.Buffer.appendLong()方法的一些代码示例，展示了Buffer.appendLong()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Buffer.appendLong()方法的具体详情如下：
包路径：io.vertx.core.buffer.Buffer
类名称：Buffer
方法名：appendLong

Buffer.appendLong介绍

[英]Appends the specified long to the end of the Buffer. The buffer will expand as necessary to accommodate any bytes written.

Returns a reference to this so multiple operations can be appended together.
[中]将指定的长度追加到缓冲区的末尾。缓冲区将根据需要扩展以容纳写入的任何字节。
返回对此的引用，以便可以将多个操作附加在一起。

代码示例

代码示例来源：origin: eclipse-vertx/vert.x

@Override
public void encodeToWire(Buffer buffer, Long l) {
 buffer.appendLong(l);
}

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testAppendLong() {
 Buffer b = Buffer.buffer(TestUtils.randomByteArray(100));
 b.appendLong(Long.MAX_VALUE);
 assertEquals(108, b.length());
 b.appendLongLE(Long.MAX_VALUE);
 assertEquals(116, b.length());
}

代码示例来源：origin: eclipse-vertx/vert.x

@Override
public void onPingRead(ChannelHandlerContext ctx, long data) throws Http2Exception {
 Handler<Buffer> handler = pingHandler;
 if (handler != null) {
  Buffer buff = Buffer.buffer().appendLong(data);
  context.executeFromIO(v -> handler.handle(buff));
 }
}

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testLE() {
 checkBEAndLE(2, Buffer.buffer().appendShort(Short.MAX_VALUE), Buffer.buffer().appendShortLE(Short.MAX_VALUE));
 checkBEAndLE(2, Buffer.buffer().appendUnsignedShort(Short.MAX_VALUE), Buffer.buffer().appendUnsignedShortLE(Short.MAX_VALUE));
 checkBEAndLE(3, Buffer.buffer().appendMedium(Integer.MAX_VALUE / 2), Buffer.buffer().appendMediumLE(Integer.MAX_VALUE / 2));
 checkBEAndLE(4, Buffer.buffer().appendInt(Integer.MAX_VALUE), Buffer.buffer().appendIntLE(Integer.MAX_VALUE));
 checkBEAndLE(4, Buffer.buffer().appendUnsignedInt(Integer.MAX_VALUE), Buffer.buffer().appendUnsignedIntLE(Integer.MAX_VALUE));
 checkBEAndLE(8, Buffer.buffer().appendLong(Long.MAX_VALUE), Buffer.buffer().appendLongLE(Long.MAX_VALUE));
}

代码示例来源：origin: eclipse-vertx/vert.x

@Override
public void onPingAckRead(ChannelHandlerContext ctx, long data) throws Http2Exception {
 Handler<AsyncResult<Buffer>> handler = pongHandlers.poll();
 if (handler != null) {
  context.executeFromIO(v -> {
   Buffer buff = Buffer.buffer().appendLong(data);
   handler.handle(Future.succeededFuture(buff));
  });
 }
}

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testAppendLong() {
 Buffer b = Buffer.buffer(TestUtils.randomByteArray(100));
 b.appendLong(Long.MAX_VALUE);
 assertEquals(108, b.length());
 b.appendLongLE(Long.MAX_VALUE);
 assertEquals(116, b.length());
}

代码示例来源：origin: io.vertx/vertx-core

@Override
public void encodeToWire(Buffer buffer, Long l) {
 buffer.appendLong(l);
}

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testLE() {
 checkBEAndLE(2, Buffer.buffer().appendShort(Short.MAX_VALUE), Buffer.buffer().appendShortLE(Short.MAX_VALUE));
 checkBEAndLE(2, Buffer.buffer().appendUnsignedShort(Short.MAX_VALUE), Buffer.buffer().appendUnsignedShortLE(Short.MAX_VALUE));
 checkBEAndLE(3, Buffer.buffer().appendMedium(Integer.MAX_VALUE / 2), Buffer.buffer().appendMediumLE(Integer.MAX_VALUE / 2));
 checkBEAndLE(4, Buffer.buffer().appendInt(Integer.MAX_VALUE), Buffer.buffer().appendIntLE(Integer.MAX_VALUE));
 checkBEAndLE(4, Buffer.buffer().appendUnsignedInt(Integer.MAX_VALUE), Buffer.buffer().appendUnsignedIntLE(Integer.MAX_VALUE));
 checkBEAndLE(8, Buffer.buffer().appendLong(Long.MAX_VALUE), Buffer.buffer().appendLongLE(Long.MAX_VALUE));
}

代码示例来源：origin: io.vertx/vertx-core

@Override
public void onPingRead(ChannelHandlerContext ctx, long data) throws Http2Exception {
 Handler<Buffer> handler = pingHandler;
 if (handler != null) {
  Buffer buff = Buffer.buffer().appendLong(data);
  context.executeFromIO(v -> handler.handle(buff));
 }
}

代码示例来源：origin: io.vertx/vertx-core

@Override
public void onPingAckRead(ChannelHandlerContext ctx, long data) throws Http2Exception {
 Handler<AsyncResult<Buffer>> handler = pongHandlers.poll();
 if (handler != null) {
  context.executeFromIO(v -> {
   Buffer buff = Buffer.buffer().appendLong(data);
   handler.handle(Future.succeededFuture(buff));
  });
 }
}

代码示例来源：origin: vert-x3/vertx-web

@Override
public void writeToBuffer(Buffer buff) {
 byte[] bytes = id().getBytes(UTF8);
 buff.appendInt(bytes.length).appendBytes(bytes);
 buff.appendLong(timeout());
 buff.appendLong(lastAccessed());
 buff.appendInt(version());
 // use cache
 Buffer dataBuf = writeDataToBuffer();
 buff.appendBuffer(dataBuf);
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Appends the specified <code>long</code> to the end of the Buffer. The buffer will expand as necessary to accommodate any bytes written.<p>
 * Returns a reference to <code>this</code> so multiple operations can be appended together.
 * @param l 
 * @return 
 */
public io.vertx.rxjava.core.buffer.Buffer appendLong(long l) { 
 delegate.appendLong(l);
 return this;
}

代码示例来源：origin: vert-x3/vertx-rx

/**
 * Appends the specified <code>long</code> to the end of the Buffer. The buffer will expand as necessary to accommodate any bytes written.<p>
 * Returns a reference to <code>this</code> so multiple operations can be appended together.
 * @param l 
 * @return 
 */
public io.vertx.rxjava.core.buffer.Buffer appendLong(long l) { 
 delegate.appendLong(l);
 return this;
}

代码示例来源：origin: vert-x3/vertx-web

Object val = entry.getValue();
if (val instanceof Long) {
 buffer.appendByte(TYPE_LONG).appendLong((long) val);
} else if (val instanceof Integer) {
 buffer.appendByte(TYPE_INT).appendInt((int) val);

代码示例来源：origin: pmlopes/vertx-bson-codec

public static void appendLong(Buffer buffer, long value) {
 buffer.appendLong(Long.reverseBytes(value));
}

代码示例来源：origin: io.vertx/vertx-web

@Override
public void writeToBuffer(Buffer buff) {
 byte[] bytes = id().getBytes(UTF8);
 buff.appendInt(bytes.length).appendBytes(bytes);
 buff.appendLong(timeout());
 buff.appendLong(lastAccessed());
 buff.appendInt(version());
 // use cache
 Buffer dataBuf = writeDataToBuffer();
 buff.appendBuffer(dataBuf);
}

代码示例来源：origin: io.vertx/vertx-web

Object val = entry.getValue();
if (val instanceof Long) {
 buffer.appendByte(TYPE_LONG).appendLong((long) val);
} else if (val instanceof Integer) {
 buffer.appendByte(TYPE_INT).appendInt((int) val);

代码示例来源：origin: pmlopes/vertx-bson-codec

buffer.appendLong(uuid.getMostSignificantBits());
 buffer.appendLong(uuid.getLeastSignificantBits());
} else if (value instanceof byte[]) {
 LE.appendByte(buffer, BINARY);

内容来源于网络，如有侵权，请联系作者删除！

Buffer

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Buffer类方法

    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com