Searched refs:headersCapture (Results 1 – 3 of 3) sorted by relevance
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | MetadataUtils.java | 105 AtomicReference<Metadata> headersCapture, in captureMetadata() argument
108 newCaptureMetadataInterceptor(headersCapture, trailersCapture)); in captureMetadata()
119 AtomicReference<Metadata> headersCapture, AtomicReference<Metadata> trailersCapture) { in newCaptureMetadataInterceptor() argument
120 return new MetadataCapturingClientInterceptor(headersCapture, trailersCapture); in newCaptureMetadataInterceptor()
125 final AtomicReference<Metadata> headersCapture; field in MetadataUtils.MetadataCapturingClientInterceptor
130 AtomicReference<Metadata> headersCapture, AtomicReference<Metadata> trailersCapture) { in MetadataCapturingClientInterceptor() argument
131 this.headersCapture = checkNotNull(headersCapture, "headersCapture"); in MetadataCapturingClientInterceptor()
151 headersCapture.set(null); in start()
165 headersCapture.set(headers); in onHeaders()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
| D | TestUtils.java | 53 final AtomicReference<Metadata> headersCapture) { in recordRequestHeadersInterceptor() argument
60 headersCapture.set(requestHeaders); in recordRequestHeadersInterceptor()
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | AbstractInteropTest.java | 991 AtomicReference<Metadata> headersCapture = new AtomicReference<Metadata>(); in exchangeMetadataUnaryCall() local
992 stub = MetadataUtils.captureMetadata(stub, headersCapture, trailersCapture); in exchangeMetadataUnaryCall()
997 Assert.assertEquals(contextValue, headersCapture.get().get(Util.METADATA_KEY)); in exchangeMetadataUnaryCall()
1014 AtomicReference<Metadata> headersCapture = new AtomicReference<Metadata>(); in exchangeMetadataStreamingCall() local
1015 stub = MetadataUtils.captureMetadata(stub, headersCapture, trailersCapture); in exchangeMetadataStreamingCall()
1045 Assert.assertEquals(contextValue, headersCapture.get().get(Util.METADATA_KEY)); in exchangeMetadataStreamingCall()
1423 AtomicReference<Metadata> headersCapture = new AtomicReference<Metadata>(); in customMetadata() local
1425 blockingStub = MetadataUtils.captureMetadata(blockingStub, headersCapture, trailersCapture); in customMetadata()
1430 headersCapture.get().get(Util.ECHO_INITIAL_METADATA_KEY)); in customMetadata()
1442 headersCapture = new AtomicReference<Metadata>(); in customMetadata()
[all …]
|