OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:headersRead
(Results
1 - 21
of
21
) sorted by null
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
ClientStreamListener.java
34
void
headersRead
(Metadata headers);
ForwardingClientStreamListener.java
28
public void
headersRead
(Metadata headers) {
29
delegate().
headersRead
(headers);
DelayedStream.java
415
public void
headersRead
(final Metadata headers) {
419
realListener.
headersRead
(headers);
AbstractClientStream.java
338
listener().
headersRead
(headers);
RetriableStream.java
536
public void
headersRead
(Metadata headers) {
539
masterListener.
headersRead
(headers);
ClientCallImpl.java
476
public void
headersRead
(final Metadata headers) {
477
class
HeadersRead
extends ContextRunnable {
478
HeadersRead
() {
498
callExecutor.execute(new
HeadersRead
());
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
NoopClientStreamListener.java
33
public void
headersRead
(Metadata headers) {}
ForwardingClientStreamListenerTest.java
56
forward.
headersRead
(headers);
57
verify(mock).
headersRead
(same(headers));
Http2ClientStreamTransportStateTest.java
84
verify(mockListener).
headersRead
(headers);
98
verify(mockListener).
headersRead
(headers);
111
verify(mockListener, never()).
headersRead
(any(Metadata.class));
126
verify(mockListener, never()).
headersRead
(any(Metadata.class));
142
verify(mockListener, never()).
headersRead
(any(Metadata.class));
168
verify(mockListener).
headersRead
(headers);
184
verify(mockListener).
headersRead
(headers);
204
verify(mockListener, never()).
headersRead
(any(Metadata.class));
247
verify(mockListener, never()).
headersRead
(any(Metadata.class));
264
verify(mockListener).
headersRead
(headers)
[
all
...]
DelayedStreamTest.java
313
passedListener.
headersRead
(headers);
323
inOrder.verify(listener).
headersRead
(headers);
344
delayedListener.
headersRead
(headers);
345
verify(listener).
headersRead
(headers);
AbstractClientStreamTest.java
189
verify(mockListener).
headersRead
(headers);
216
verify(mockListener).
headersRead
(headers);
231
verify(mockListener).
headersRead
(headers);
286
verify(mockListener).
headersRead
(headers);
298
verify(mockListener).
headersRead
(headers);
ClientCallImplTest.java
157
streamListener.
headersRead
(new Metadata());
179
streamListener.
headersRead
(new Metadata());
222
* queued to run. When
headersRead
is called, an exception will occur and attempt to cancel the
226
streamListener.
headersRead
(new Metadata());
564
listener.
headersRead
(new Metadata());
903
streamListener.
headersRead
(new Metadata());
[
all
...]
RetriableStreamTest.java
353
sublistenerCaptor1.getValue().
headersRead
(new Metadata());
386
//
headersRead
387
sublistenerCaptor2.getValue().
headersRead
(new Metadata());
409
sublistenerCaptor1.getValue().
headersRead
(new Metadata());
444
//
headersRead
445
sublistenerCaptor2.getValue().
headersRead
(new Metadata());
648
sublistenerCaptor2.get().
headersRead
(new Metadata());
722
sublistenerCaptor1.getValue().
headersRead
(new Metadata());
[
all
...]
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
InProcessTransport.java
413
clientStreamListener.
headersRead
(headers);
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
NettyClientHandlerTest.java
312
verify(streamListener).
headersRead
(captor.capture());
NettyClientStreamTest.java
250
verify(listener).
headersRead
(any(Metadata.class));
NettyClientTransportTest.java
685
public void
headersRead
(Metadata headers) {
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
CronetClientStreamTest.java
245
verify(clientListener).
headersRead
(metadataCaptor.capture());
[
all
...]
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
AbstractTransportTest.java
282
verify(mockClientStreamListener2, timeout(250)).
headersRead
(any(Metadata.class));
[
all
...]
/external/grpc-grpc-java/core/
grpc-core-1.14.0.jar
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
OkHttpClientTransportTest.java
[
all
...]
Completed in 344 milliseconds