Searched refs:Unpooled (Results 1 – 17 of 17) sorted by relevance
28 import io.netty.buffer.Unpooled;73 encodedHeaders = Unpooled.buffer(); in decode_requestHeaders()100 encodedHeaders = Unpooled.buffer(); in decode_responseHeaders()119 ByteBuf encodedHeaders = Unpooled.buffer(); in decode_emptyHeaders()
21 import io.netty.buffer.Unpooled;38 buffer = new NettyWritableBuffer(Unpooled.buffer(100)); in setup()
24 import io.netty.buffer.Unpooled;39 buffer = new NettyReadableBuffer(Unpooled.copiedBuffer(msg, UTF_8)); in setup()
23 import io.netty.buffer.Unpooled;50 ByteBuf buf = Unpooled.buffer(); in compressionFrame()
71 import io.netty.buffer.Unpooled;380 channelRead(goAwayFrame(0, 8 /* Cancel */, Unpooled.copiedBuffer("this is a test", UTF_8))); in receivedGoAwayShouldFailUnknownStreams()395 channelRead(goAwayFrame(0, 8 /* Cancel */, Unpooled.copiedBuffer("this is a test", UTF_8))); in receivedGoAwayShouldFailUnknownBufferedStreams()407 channelRead(goAwayFrame(0, 8 /* Cancel */, Unpooled.copiedBuffer("this is a test", UTF_8))); in receivedGoAwayShouldFailNewStreams()426 Unpooled.copiedBuffer(new byte[] {(byte) 0xFF, (byte) 0xF0, (byte) 0x0a}))); in receivedGoAway_notUtf8()441 Unpooled.copiedBuffer("not_many_pings", UTF_8))); in receivedGoAway_enhanceYourCalmWithoutTooManyPings()457 Unpooled.copiedBuffer("too_many_pings", UTF_8))); in receivedGoAway_enhanceYourCalmWithTooManyPings()
42 import io.netty.buffer.Unpooled;115 content = Unpooled.copiedBuffer("hello world", UTF_8); in initChannel()247 final ByteBuf compressionFrame = Unpooled.buffer(content.length); in grpcDataFrame()291 return goAwayFrame(lastStreamId, 0, Unpooled.EMPTY_BUFFER); in goAwayFrame()345 CompositeByteBuf composite = Unpooled.compositeBuffer(); in captureWrite()
57 import io.netty.buffer.Unpooled;310 stream().transportState().transportDataReceived(Unpooled.buffer(100).writeZero(100), false); in invalidInboundHeadersCancelStream()312 stream().transportState().transportDataReceived(Unpooled.buffer(1000).writeZero(1000), false); in invalidInboundHeadersCancelStream()347 stream().transportState().transportDataReceived(Unpooled.copiedBuffer(MESSAGE, UTF_8), true); in nonGrpcResponseShouldSetStatus()528 return Unpooled.wrappedBuffer(new byte[] {0, 0, 0, 0, 2, 3, 14}); in simpleGrpcFrame()
72 import io.netty.buffer.Unpooled;337 eq(Unpooled.EMPTY_BUFFER), any(ChannelPromise.class)); in closeShouldCloseChannel()
27 import io.netty.buffer.Unpooled;126 ByteBuf plaintextBuffer = Unpooled.wrappedBuffer(message.getBytes(UTF_8)); in sendMessage()155 assertThat(plaintextRecvd).isEqualTo(Unpooled.wrappedBuffer(message.getBytes(UTF_8))); in sendMessage()260 ByteBuf plaintextBuffer = Unpooled.wrappedBuffer(message.getBytes(UTF_8)); in corruptedCounterTest()301 ByteBuf plaintextBuffer = Unpooled.wrappedBuffer(message.getBytes(UTF_8)); in corruptedCiphertextTest()340 ByteBuf plaintextBuffer = Unpooled.wrappedBuffer(message.getBytes(UTF_8)); in corruptedTagTest()379 ByteBuf plaintextBuffer = Unpooled.wrappedBuffer(message.getBytes(UTF_8)); in reflectedCiphertextTest()
21 import io.netty.buffer.Unpooled;37 return ref.register(Unpooled.directBuffer(len)); in getDirectBuffer()
38 import io.netty.buffer.Unpooled;179 ByteBuf in = Unpooled.copiedBuffer(message, ix, 1, UTF_8); in protectShouldRoundtrip()245 ByteBuf unprotectedData = Unpooled.wrappedBuffer(unprotectedBytes); in unprotectLargeIncomingFrame()296 ByteBuf in = Unpooled.copiedBuffer(message, ix, 1, UTF_8); in flushShouldFailAllPromises()324 ByteBuf in = Unpooled.copiedBuffer(message, UTF_8); in doNotFlushEmptyBuffer()332 done = channel.write(Unpooled.EMPTY_BUFFER); in doNotFlushEmptyBuffer()
27 import io.netty.buffer.Unpooled;138 ByteBuf plain = Unpooled.wrappedBuffer(plain1, plain2); in encryptDecryptComposite()152 ByteBuf cipher = Unpooled.wrappedBuffer(cipher1, cipher2); in encryptDecryptComposite()
21 import io.netty.buffer.Unpooled;70 channels[0].newCall(unaryMethod, CallOptions.DEFAULT), Unpooled.EMPTY_BUFFER); in blockingUnary()
27 TEST(PoolTest, Unpooled) { in TEST() argument
22 import static io.netty.buffer.Unpooled.EMPTY_BUFFER;
40 import io.netty.buffer.Unpooled;312 ctx.write(Unpooled.EMPTY_BUFFER, promise); in write()
META-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...