Searched refs:mockTransport (Results 1 – 3 of 3) sorted by relevance
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | CallCredentialsApplyingTest.java | 63 private ConnectionClientTransport mockTransport; field in CallCredentialsApplyingTest
109 .thenReturn(mockTransport); in setUp()
110 when(mockTransport.newStream(same(method), any(Metadata.class), any(CallOptions.class))) in setUp()
118 assertSame(mockTransport, transport.delegate()); in setUp()
124 when(mockTransport.getAttributes()).thenReturn(transportAttrs); in parameterPropagation_base()
144 when(mockTransport.getAttributes()).thenReturn(transportAttrs); in parameterPropagation_overrideByTransport()
164 when(mockTransport.getAttributes()).thenReturn(transportAttrs); in parameterPropagation_overrideByCallOptions()
182 when(mockTransport.getAttributes()).thenReturn(Attributes.EMPTY); in credentialThrows()
189 verify(mockTransport, never()).newStream(method, origHeaders, callOptions); in credentialThrows()
196 when(mockTransport.getAttributes()).thenReturn(Attributes.EMPTY); in applyMetadata_inline()
[all …]
|
| D | TestUtils.java | 77 final ConnectionClientTransport mockTransport = mock(ConnectionClientTransport.class); in captureTransports()
78 when(mockTransport.getLogId()).thenReturn(InternalLogId.allocate("mocktransport")); in captureTransports()
79 when(mockTransport.newStream( in captureTransports()
87 mockTransport, (ManagedClientTransport.Listener) invocation.getArguments()[0])); in captureTransports()
90 }).when(mockTransport).start(any(ManagedClientTransport.Listener.class)); in captureTransports()
91 return mockTransport; in captureTransports()
|
| D | ManagedChannelImplTest.java | 443 ConnectionClientTransport mockTransport = transportInfo.transport; in subtestCallsAndShutdown() local
444 verify(mockTransport).start(any(ManagedClientTransport.Listener.class)); in subtestCallsAndShutdown()
446 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()
465 verify(mockTransport, never()) 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()
528 verify(mockTransport).shutdownNow(ManagedChannelImpl.SHUTDOWN_NOW_STATUS); in subtestCallsAndShutdown()
530 verify(mockTransport, never()).shutdownNow(any(Status.class)); in subtestCallsAndShutdown()
[all …]
|