Home
last modified time | relevance | path

Searched refs:mockTransport (Results 1 – 4 of 4) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DCallCredentials2ApplyingTest.java64 private ConnectionClientTransport mockTransport; field in CallCredentials2ApplyingTest
110 .thenReturn(mockTransport); in setUp()
111 when(mockTransport.newStream(same(method), any(Metadata.class), any(CallOptions.class))) in setUp()
119 assertSame(mockTransport, transport.delegate()); in setUp()
125 when(mockTransport.getAttributes()).thenReturn(transportAttrs); in parameterPropagation_base()
146 when(mockTransport.getAttributes()).thenReturn(transportAttrs); in parameterPropagation_transportSetSecurityLevel()
165 when(mockTransport.getAttributes()).thenReturn(transportAttrs); in parameterPropagation_callOptionsSetAuthority()
184 when(mockTransport.getAttributes()).thenReturn(Attributes.EMPTY); in credentialThrows()
191 verify(mockTransport, never()).newStream(method, origHeaders, callOptions); in credentialThrows()
198 when(mockTransport.getAttributes()).thenReturn(Attributes.EMPTY); in applyMetadata_inline()
[all …]
DCallCredentialsApplyingTest.java63 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()
190 verify(mockTransport, never()).newStream(method, origHeaders, callOptions); in credentialThrows()
197 when(mockTransport.getAttributes()).thenReturn(Attributes.EMPTY); in applyMetadata_inline()
[all …]
DTestUtils.java77 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()
DManagedChannelImplTest.java442 ConnectionClientTransport mockTransport = transportInfo.transport; in subtestCallsAndShutdown() local
443 verify(mockTransport).start(any(ManagedClientTransport.Listener.class)); in subtestCallsAndShutdown()
445 when(mockTransport.newStream(same(method), same(headers), same(CallOptions.DEFAULT))) in subtestCallsAndShutdown()
447 when(mockTransport.newStream(same(method), same(headers2), same(CallOptions.DEFAULT))) in subtestCallsAndShutdown()
464 verify(mockTransport, never()) in subtestCallsAndShutdown()
470 verify(mockTransport).newStream(same(method), same(headers2), same(CallOptions.DEFAULT)); in subtestCallsAndShutdown()
471 verify(mockTransport).newStream(same(method), same(headers2), same(CallOptions.DEFAULT)); in subtestCallsAndShutdown()
516 verify(mockTransport).newStream(same(method), same(headers), same(CallOptions.DEFAULT)); in subtestCallsAndShutdown()
527 verify(mockTransport).shutdownNow(ManagedChannelImpl.SHUTDOWN_NOW_STATUS); in subtestCallsAndShutdown()
529 verify(mockTransport, never()).shutdownNow(any(Status.class)); in subtestCallsAndShutdown()
[all …]