本文整理了Java中io.vertx.core.buffer.Buffer.appendUnsignedShort()
方法的一些代码示例,展示了Buffer.appendUnsignedShort()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Buffer.appendUnsignedShort()
方法的具体详情如下:
包路径:io.vertx.core.buffer.Buffer
类名称:Buffer
方法名:appendUnsignedShort
[英]Appends the specified unsigned short 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
public static String encodeSettings(io.vertx.core.http.Http2Settings settings) {
Buffer buffer = Buffer.buffer();
fromVertxSettings(settings).forEach((c, l) -> {
buffer.appendUnsignedShort(c);
buffer.appendUnsignedInt(l);
});
return Base64.getUrlEncoder().encodeToString(buffer.getBytes());
}
代码示例来源:origin: eclipse-vertx/vert.x
@Test
public void testAppendUnsignedShort() {
Buffer b = Buffer.buffer(TestUtils.randomByteArray(100));
b.appendUnsignedShort(Short.MAX_VALUE + Short.MAX_VALUE / 2);
assertEquals(102, b.length());
b.appendUnsignedShortLE(Short.MAX_VALUE + Short.MAX_VALUE / 2);
assertEquals(104, b.length());
}
代码示例来源: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 Collection<CharSequence> setUpgradeHeaders(ChannelHandlerContext ctx, HttpRequest upgradeRequest) {
Http2Settings nettySettings = new Http2Settings();
HttpUtils.fromVertxInitialSettings(false, settings, nettySettings);
Buffer buf = Buffer.buffer();
for (CharObjectMap.PrimitiveEntry<Long> entry : nettySettings.entries()) {
buf.appendUnsignedShort(entry.key());
buf.appendUnsignedInt(entry.value());
}
String encodedSettings = new String(java.util.Base64.getUrlEncoder().encode(buf.getBytes()), UTF_8);
upgradeRequest.headers().set(HTTP_UPGRADE_SETTINGS_HEADER, encodedSettings);
return UPGRADE_HEADERS;
}
代码示例来源:origin: io.vertx/vertx-core
@Test
public void testAppendUnsignedShort() {
Buffer b = Buffer.buffer(TestUtils.randomByteArray(100));
b.appendUnsignedShort(Short.MAX_VALUE + Short.MAX_VALUE / 2);
assertEquals(102, b.length());
b.appendUnsignedShortLE(Short.MAX_VALUE + Short.MAX_VALUE / 2);
assertEquals(104, b.length());
}
代码示例来源:origin: io.vertx/vertx-core
public static String encodeSettings(io.vertx.core.http.Http2Settings settings) {
Buffer buffer = Buffer.buffer();
fromVertxSettings(settings).forEach((c, l) -> {
buffer.appendUnsignedShort(c);
buffer.appendUnsignedInt(l);
});
return Base64.getUrlEncoder().encodeToString(buffer.getBytes());
}
代码示例来源: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 Collection<CharSequence> setUpgradeHeaders(ChannelHandlerContext ctx, HttpRequest upgradeRequest) {
Http2Settings nettySettings = new Http2Settings();
HttpUtils.fromVertxInitialSettings(false, settings, nettySettings);
Buffer buf = Buffer.buffer();
for (CharObjectMap.PrimitiveEntry<Long> entry : nettySettings.entries()) {
buf.appendUnsignedShort(entry.key());
buf.appendUnsignedInt(entry.value());
}
String encodedSettings = new String(java.util.Base64.getUrlEncoder().encode(buf.getBytes()), UTF_8);
upgradeRequest.headers().set(HTTP_UPGRADE_SETTINGS_HEADER, encodedSettings);
return UPGRADE_HEADERS;
}
代码示例来源:origin: io.vertx/vertx-rx-java
/**
* Appends the specified unsigned <code>short</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 s
* @return
*/
public io.vertx.rxjava.core.buffer.Buffer appendUnsignedShort(int s) {
delegate.appendUnsignedShort(s);
return this;
}
代码示例来源:origin: vert-x3/vertx-rx
/**
* Appends the specified unsigned <code>short</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 s
* @return
*/
public io.vertx.rxjava.core.buffer.Buffer appendUnsignedShort(int s) {
delegate.appendUnsignedShort(s);
return this;
}
内容来源于网络,如有侵权,请联系作者删除!