Home
last modified time | relevance | path

Searched refs:metadataCaptor (Results 1 – 7 of 7) sorted by relevance

/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/header/
DHeaderClientInterceptorTest.java88 ArgumentCaptor<Metadata> metadataCaptor = ArgumentCaptor.forClass(Metadata.class); in clientHeaderDeliveredToServer() local
99 metadataCaptor.capture(), in clientHeaderDeliveredToServer()
103 metadataCaptor.getValue().get(HeaderClientInterceptor.CUSTOM_HEADER_KEY)); in clientHeaderDeliveredToServer()
DHeaderServerInterceptorTest.java111 ArgumentCaptor<Metadata> metadataCaptor = ArgumentCaptor.forClass(Metadata.class); in serverHeaderDeliveredToClient()
116 verify(clientInterceptor.spyListener).onHeaders(metadataCaptor.capture()); in serverHeaderDeliveredToClient()
119 metadataCaptor.getValue().get(HeaderServerInterceptor.CUSTOM_HEADER_KEY)); in serverHeaderDeliveredToClient()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAbstractServerStreamTest.java70 private final ArgumentCaptor<Metadata> metadataCaptor = ArgumentCaptor.forClass(Metadata.class); field in AbstractServerStreamTest
327 verify(sink).writeTrailers(metadataCaptor.capture(), eq(false), eq(closeStatus)); in close_sendTrailersClearsReservedFields()
329 Status.Code.INTERNAL, metadataCaptor.getValue().get(InternalStatus.CODE_KEY).getCode()); in close_sendTrailersClearsReservedFields()
330 assertEquals("bad", metadataCaptor.getValue().get(InternalStatus.MESSAGE_KEY)); in close_sendTrailersClearsReservedFields()
DClientCallImplTest.java286 ArgumentCaptor<Metadata> metadataCaptor = ArgumentCaptor.forClass(Metadata.class); in advertisedEncodingsAreSent() local
287 verify(transport).newStream(eq(method), metadataCaptor.capture(), same(baseCallOptions)); in advertisedEncodingsAreSent()
288 Metadata actual = metadataCaptor.getValue(); in advertisedEncodingsAreSent()
DServerImplTest.java184 private ArgumentCaptor<Metadata> metadataCaptor; field in ServerImplTest
1347 verify(stream).close(statusCaptor.capture(), metadataCaptor.capture()); in ensureServerStateNotLeaked()
1350 assertTrue(metadataCaptor.getValue().keys().isEmpty()); in ensureServerStateNotLeaked()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientStreamTest.java317 ArgumentCaptor<Metadata> metadataCaptor = ArgumentCaptor.forClass(Metadata.class); in invalidInboundHeadersCancelStream() local
318 verify(listener).closed(captor.capture(), same(PROCESSED), metadataCaptor.capture()); in invalidInboundHeadersCancelStream()
320 assertEquals("4", metadataCaptor.getValue() in invalidInboundHeadersCancelStream()
336 ArgumentCaptor<Metadata> metadataCaptor = ArgumentCaptor.forClass(Metadata.class); in invalidInboundContentTypeShouldCancelStream() local
337 verify(listener).closed(captor.capture(), same(PROCESSED), metadataCaptor.capture()); in invalidInboundContentTypeShouldCancelStream()
341 assertEquals("application/bad", metadataCaptor.getValue() in invalidInboundContentTypeShouldCancelStream()
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
DCronetClientStreamTest.java244 ArgumentCaptor<Metadata> metadataCaptor = ArgumentCaptor.forClass(Metadata.class); in read() local
245 verify(clientListener).headersRead(metadataCaptor.capture()); in read()
247 Metadata metadata = metadataCaptor.getValue(); in read()