Home
last modified time | relevance | path

Searched refs:newStream (Results 1 – 25 of 50) sorted by relevance

12

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedClientTransportTest.java111 when(mockRealTransport.newStream(same(method), same(headers), same(callOptions))) in setUp()
113 when(mockRealTransport2.newStream(same(method2), same(headers2), same(callOptions2))) in setUp()
124 ClientStream stream = delayedTransport.newStream(method, headers, callOptions); in streamStartThenAssignTransport()
134 verify(mockRealTransport).newStream(same(method), same(headers), same(callOptions)); in streamStartThenAssignTransport()
143 ClientStream stream = delayedTransport.newStream(method, headers, callOptions); in newStreamThenAssignTransportThenShutdown()
152 verify(mockRealTransport).newStream(same(method), same(headers), same(callOptions)); in newStreamThenAssignTransportThenShutdown()
170 ClientStream stream = delayedTransport.newStream(method, headers, callOptions); in assignTransportThenShutdownThenNewStream()
173 verify(mockRealTransport, never()).newStream( in assignTransportThenShutdownThenNewStream()
182 ClientStream stream = delayedTransport.newStream(method, headers, callOptions); in assignTransportThenShutdownNowThenNewStream()
185 verify(mockRealTransport, never()).newStream( in assignTransportThenShutdownNowThenNewStream()
[all …]
DCallCredentialsApplyingTest.java110 when(mockTransport.newStream(same(method), any(Metadata.class), any(CallOptions.class))) in setUp()
126 transport.newStream(method, origHeaders, callOptions); in parameterPropagation_base()
146 transport.newStream(method, origHeaders, callOptions); in parameterPropagation_overrideByTransport()
167 transport.newStream(method, origHeaders, in parameterPropagation_overrideByCallOptions()
187 (FailingClientStream) transport.newStream(method, origHeaders, callOptions); in credentialThrows()
189 verify(mockTransport, never()).newStream(method, origHeaders, callOptions); in credentialThrows()
209 ClientStream stream = transport.newStream(method, origHeaders, callOptions); in applyMetadata_inline()
211 verify(mockTransport).newStream(method, origHeaders, callOptions); in applyMetadata_inline()
232 (FailingClientStream) transport.newStream(method, origHeaders, callOptions); in fail_inline()
234 verify(mockTransport, never()).newStream(method, origHeaders, callOptions); in fail_inline()
[all …]
DManagedChannelImplTest.java446 when(mockTransport.newStream(same(method), same(headers), same(CallOptions.DEFAULT))) in subtestCallsAndShutdown()
448 when(mockTransport.newStream(same(method), same(headers2), same(CallOptions.DEFAULT))) in subtestCallsAndShutdown()
466 .newStream(same(method), same(headers), same(CallOptions.DEFAULT)); in subtestCallsAndShutdown()
471 verify(mockTransport).newStream(same(method), same(headers2), same(CallOptions.DEFAULT)); in subtestCallsAndShutdown()
472 verify(mockTransport).newStream(same(method), same(headers2), same(CallOptions.DEFAULT)); in subtestCallsAndShutdown()
517 verify(mockTransport).newStream(same(method), same(headers), same(CallOptions.DEFAULT)); in subtestCallsAndShutdown()
646 when(mockTransport.newStream(same(method), same(headers), any(CallOptions.class))) in callOptionsExecutor()
656 verify(mockTransport).newStream(same(method), same(headers), same(options)); in callOptionsExecutor()
876 when(goodTransportInfo.transport.newStream( in firstResolvedServerFailedToConnect()
890 verify(goodTransportInfo.transport).newStream(same(method), same(headers), in firstResolvedServerFailedToConnect()
[all …]
DGrpcUtilTest.java247 .newStream(TestMethodDescriptors.voidMethod(), new Metadata(), CallOptions.DEFAULT); in getTransportFromPickResult_errorPickResult_failFast()
263 .newStream(TestMethodDescriptors.voidMethod(), new Metadata(), CallOptions.DEFAULT); in getTransportFromPickResult_dropPickResult_waitForReady()
279 .newStream(TestMethodDescriptors.voidMethod(), new Metadata(), CallOptions.DEFAULT); in getTransportFromPickResult_dropPickResult_failFast()
DFailingClientTransportTest.java45 .newStream(TestMethodDescriptors.voidMethod(), new Metadata(), CallOptions.DEFAULT); in newStreamStart()
/external/antlr/tool/src/test/java/org/antlr/test/
DTestTreeNodeStream.java41 public TreeNodeStream newStream(Object t) { in newStream() method in TestTreeNodeStream
52 TreeNodeStream stream = newStream(t); in testSingleNode()
69 TreeNodeStream stream = newStream(t); in test4Nodes()
92 TreeNodeStream stream = newStream(root); in testList()
109 TreeNodeStream stream = newStream(root); in testFlatList()
124 TreeNodeStream stream = newStream(root); in testListWithOneNode()
138 TreeNodeStream stream = newStream(t); in testAoverB()
155 TreeNodeStream stream = newStream(t); in testLT()
183 TreeNodeStream stream = newStream(r0); in testMarkRewindEntire()
214 TreeNodeStream stream = newStream(r0); in testMarkRewindInMiddle()
[all …]
DTestBufferedTreeNodeStream.java43 public TreeNodeStream newStream(Object t) { in newStream() method in TestBufferedTreeNodeStream
66 TreeNodeStream stream = newStream(r0); in testSeek()
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientTransportTest.java251 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in maxMessageSizeShouldBeEnforced()
277 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in nextFrameThrowIoException()
281 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in nextFrameThrowIoException()
311 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in nextFrameThrowsError()
332 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in nextFrameReturnFalse()
350 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in readMessages()
400 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in invalidInboundHeadersCancelStream()
424 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in invalidInboundTrailersPropagateToMetadata()
444 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in readStatus()
458 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in receiveReset()
[all …]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/
DSpdy3ConnectionTest.java78 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true); in clientCreatesStreamAndServerReplies()
107 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, false); in headersOnlyStreamIsClosedAfterReplyHeaders()
124 connection.newStream(headerEntries("b", "banana"), false, true); in clientCreatesStreamAndServerRepliesWithFin()
401 FramedStream stream = connection.newStream(headerEntries("a", "android"), true, false);
444 FramedStream stream = connection.newStream(headerEntries("a", "android"), true, true);
485 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, true);
529 FramedStream stream = connection.newStream(headerEntries("a", "android"), true, true);
573 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, true);
599 FramedStream stream = connection.newStream(headerEntries("c", "cola"), true, true);
667 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
[all …]
DHttp2ConnectionTest.java131 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, true);
190 FramedStream stream1 = connection.newStream(headerEntries("a", "android"), true, true);
191 FramedStream stream2 = connection.newStream(headerEntries("b", "banana"), true, true);
206 connection.newStream(headerEntries("c", "cola"), true, true);
251 FramedStream stream = connection.newStream(headerEntries("b", "banana"), false, true);
290 FramedStream client = connection.newStream(headerEntries("b", "banana"), false, true);
310 FramedStream client = connection.newStream(headerEntries("b", "banana"), true, true);
337 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
376 FramedStream client = connection.newStream(headerEntries("b", "banana"), false, true);
398 connection.newStream(headerEntries("b", "banana"), false, true);
[all …]
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java252 ClientStream stream = client.newStream(methodDescriptor, new Metadata(), callOptions); in frameAfterRstStreamShouldNotBreakClientChannel()
275 stream = client.newStream(methodDescriptor, new Metadata(), callOptions); in frameAfterRstStreamShouldNotBreakClientChannel()
370 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in openStreamPreventsTermination()
422 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in shutdownNowKillsClientStream()
459 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in shutdownNowKillsServerStream()
513 ClientStream stream = client.newStream(methodDescriptor, new Metadata(), callOptions); in ping_duringShutdown()
557 ClientStream stream = client.newStream(methodDescriptor, new Metadata(), callOptions); in newStream_duringShutdown()
565 ClientStream stream2 = client.newStream(methodDescriptor, new Metadata(), callOptions); in newStream_duringShutdown()
601 ClientStream stream = client.newStream(methodDescriptor, new Metadata(), callOptions); in newStream_afterTermination()
620 ClientStream stream1 = client.newStream(methodDescriptor, new Metadata(), callOptions); in transportInUse_normalClose()
[all …]
/external/archive-patcher/generator/src/main/java/com/google/archivepatcher/generator/
DDefaultDeflateCompressionDiviner.java105 try (InputStream is = isFactory.newStream()) { in divineDeflateParameters()
226 compressedDataInputStreamFactory.newStream(), copyBuffer.length); in matches()
229 compressedDataInputStreamFactory.newStream(), inflater, copyBuffer.length); in matches()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DForwardingConnectionClientTransport.java47 public ClientStream newStream( in newStream() method in ForwardingConnectionClientTransport
49 return delegate().newStream(method, headers, callOptions); in newStream()
DCallCredentialsApplyingTransportFactory.java75 public ClientStream newStream( in newStream() method in CallCredentialsApplyingTransportFactory.CallCredentialsApplyingTransport
98 return delegate.newStream(method, headers, callOptions); in newStream()
DDelayedClientTransport.java131 public final ClientStream newStream( in newStream() method in DelayedClientTransport
153 return transport.newStream( in newStream()
358 realStream = transport.newStream( in createRealStream()
DClientTransport.java52 ClientStream newStream(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions); in newStream() method
DFailingClientTransport.java47 public ClientStream newStream( in newStream() method in FailingClientTransport
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/
DFramedConnection.java236 return newStream(associatedStreamId, requestHeaders, out, false); in pushStream()
247 public FramedStream newStream(List<Header> requestHeaders, boolean out, boolean in) in newStream() method in FramedConnection
249 return newStream(0, requestHeaders, out, in); in newStream()
252 private FramedStream newStream(int associatedStreamId, List<Header> requestHeaders, boolean out, in newStream() method in FramedConnection
668 newStream = new FramedStream(streamId, FramedConnection.this, outFinished, in headers()
671 streams.put(streamId, newStream); in headers()
675 listener.onStream(newStream); in headers()
679 newStream.close(ErrorCode.PROTOCOL_ERROR); in headers()
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/
DFramedConnection.java238 return newStream(associatedStreamId, requestHeaders, out, false); in pushStream()
249 public FramedStream newStream(List<Header> requestHeaders, boolean out, boolean in) in newStream() method in FramedConnection
251 return newStream(0, requestHeaders, out, in); in newStream()
254 private FramedStream newStream(int associatedStreamId, List<Header> requestHeaders, boolean out, in newStream() method in FramedConnection
673 newStream = new FramedStream(streamId, FramedConnection.this, outFinished, in headers()
676 streams.put(streamId, newStream); in headers()
680 listener.onStream(newStream); in headers()
684 newStream.close(ErrorCode.PROTOCOL_ERROR); in headers()
/external/archive-patcher/shared/src/test/java/com/google/archivepatcher/shared/
DRandomAccessFileInputStreamFactoryTest.java75 RandomAccessFileInputStream rafis1 = factory.newStream(); in testNewStream_MakesIdenticalStreams()
76 RandomAccessFileInputStream rafis2 = factory.newStream(); in testNewStream_MakesIdenticalStreams()
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
DCronetChannelBuilderTest.java65 CronetClientStream stream = transport.newStream(method, new Metadata(), CallOptions.DEFAULT); in alwaysUsePutTrue_cronetStreamIsIdempotent()
79 CronetClientStream stream = transport.newStream(method, new Metadata(), CallOptions.DEFAULT); in alwaysUsePut_defaultsToFalse()
DCronetClientTransportTest.java93 transport.newStream(descriptor, new Metadata(), CallOptions.DEFAULT); in shutdownTransport()
95 transport.newStream(descriptor, new Metadata(), CallOptions.DEFAULT); in shutdownTransport()
/external/archive-patcher/shared/src/main/java/com/google/archivepatcher/shared/
DMultiViewInputStreamFactory.java33 public InputStream newStream() throws IOException; in newStream() method
DByteArrayInputStreamFactory.java33 public ByteArrayInputStream newStream() throws IOException { in newStream() method in ByteArrayInputStreamFactory
DRandomAccessFileInputStreamFactory.java55 public RandomAccessFileInputStream newStream() throws IOException { in newStream() method in RandomAccessFileInputStreamFactory

12