HomeSort by relevance Sort by last modified time
    Searched refs:mockTransport (Results 1 - 3 of 3) sorted by null

  /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
TestUtils.java 77 final ConnectionClientTransport mockTransport = mock(ConnectionClientTransport.class);
78 when(mockTransport.getLogId()).thenReturn(InternalLogId.allocate("mocktransport"));
79 when(mockTransport.newStream(
87 mockTransport, (ManagedClientTransport.Listener) invocation.getArguments()[0]));
90 }).when(mockTransport).start(any(ManagedClientTransport.Listener.class));
91 return mockTransport;
CallCredentialsApplyingTest.java 63 private ConnectionClientTransport mockTransport;
109 .thenReturn(mockTransport);
110 when(mockTransport.newStream(same(method), any(Metadata.class), any(CallOptions.class)))
118 assertSame(mockTransport, transport.delegate());
124 when(mockTransport.getAttributes()).thenReturn(transportAttrs);
144 when(mockTransport.getAttributes()).thenReturn(transportAttrs);
164 when(mockTransport.getAttributes()).thenReturn(transportAttrs);
182 when(mockTransport.getAttributes()).thenReturn(Attributes.EMPTY);
189 verify(mockTransport, never()).newStream(method, origHeaders, callOptions);
196 when(mockTransport.getAttributes()).thenReturn(Attributes.EMPTY)
    [all...]
ManagedChannelImplTest.java 443 ConnectionClientTransport mockTransport = transportInfo.transport;
444 verify(mockTransport).start(any(ManagedClientTransport.Listener.class));
446 when(mockTransport.newStream(same(method), same(headers), same(CallOptions.DEFAULT)))
448 when(mockTransport.newStream(same(method), same(headers2), same(CallOptions.DEFAULT)))
465 verify(mockTransport, never())
471 verify(mockTransport).newStream(same(method), same(headers2), same(CallOptions.DEFAULT));
472 verify(mockTransport).newStream(same(method), same(headers2), same(CallOptions.DEFAULT));
517 verify(mockTransport).newStream(same(method), same(headers), same(CallOptions.DEFAULT));
528 verify(mockTransport).shutdownNow(ManagedChannelImpl.SHUTDOWN_NOW_STATUS);
530 verify(mockTransport, never()).shutdownNow(any(Status.class))
    [all...]

Completed in 548 milliseconds