Home
last modified time | relevance | path

Searched refs:createMessageFrame (Results 1 – 2 of 2) sorted by relevance

/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientTransportTest.java260 Buffer buffer = createMessageFrame(message); in maxMessageSizeShouldBeEnforced()
357 Buffer buffer = createMessageFrame(message + i); in readMessages()
387 frameHandler().data(false, 3, createMessageFrame(new String(new char[1000])), 1000); in receivedDataForInvalidStreamShouldKillConnection()
409 frameHandler().data(false, 3, createMessageFrame(new String(new char[1000])), 1000); in invalidInboundHeadersCancelStream()
551 assertEquals(createMessageFrame(message), sentFrame); in writeMessage()
605 Buffer buffer = createMessageFrame(fakeMessage); in windowUpdate()
610 buffer = createMessageFrame(fakeMessage); in windowUpdate()
618 buffer = createMessageFrame(fakeMessage); in windowUpdate()
625 buffer = createMessageFrame(fakeMessage); in windowUpdate()
658 Buffer buffer = createMessageFrame(fakeMessage); in windowUpdateWithInboundFlowControl()
[all …]
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
DCronetClientStreamTest.java220 private static ByteBuffer createMessageFrame(byte[] bytes) { in createMessageFrame() method in CronetClientStreamTest
257 (ByteBuffer) createMessageFrame(new String("response1").getBytes(Charset.forName("UTF-8"))), in read()
308 (ByteBuffer) createMessageFrame(new String("response").getBytes(Charset.forName("UTF-8"))), in streamSucceeded()