Searched refs:testHandler (Results 1 – 6 of 6) sorted by relevance
85 TestHandler testHandler = new TestHandler(); in eventStreamOperation_unmarshallsHeaderMembersIntoResponse() local86 client.eventStreamOperation(r -> {}, testHandler).join(); in eventStreamOperation_unmarshallsHeaderMembersIntoResponse()88 assertThat(testHandler.receivedResponse.headerMember()).isEqualTo(expectedValue); in eventStreamOperation_unmarshallsHeaderMembersIntoResponse()98 TestHandler testHandler = new TestHandler(); in unknownEventType_unmarshallsToUnknown() local99 client.eventStreamOperation(r -> {}, testHandler).join(); in unknownEventType_unmarshallsToUnknown()101 assertThat(testHandler.receivedEvents).containsExactly(EventStream.UNKNOWN); in unknownEventType_unmarshallsToUnknown()102 …assertThat(testHandler.receivedEvents.get(0).sdkEventType()).isEqualTo(EventStream.EventType.UNKNO… in unknownEventType_unmarshallsToUnknown()114 TestHandler testHandler = new TestHandler(); in eventPayloadEvent_unmarshallsToEventPayloadEvent() local115 client.eventStreamOperation(r -> {}, testHandler).join(); in eventPayloadEvent_unmarshallsToEventPayloadEvent()117 …assertThat(testHandler.receivedEvents).containsExactly(EventStream.eventPayloadEventBuilder().foo(… in eventPayloadEvent_unmarshallsToEventPayloadEvent()[all …]
48 private static final TestHandler testHandler = new TestHandler(); field in UrlInstrumentationIT52 Tracing.getExportComponent().getSpanExporter().registerHandler("test", testHandler); in beforeClass()69 SpanData span = testHandler.waitForExport(1).get(0); in getContent()82 SpanData span = testHandler.waitForExport(1).get(0); in getContent_fails()
113 def testHandler(signum, frame): function117 signal.signal(signal.SIGALRM, testHandler)130 def testHandler(signum, frame): function136 signal.signal(signal.SIGALRM, testHandler)
118 TestHandler testHandler = new TestHandler(); in selectObjectContent_canUnmarshallAllEvents() local119 runSimpleQuery(s3, testHandler).join(); in selectObjectContent_canUnmarshallAllEvents()121 assertThat(testHandler.receivedEvents).isEqualTo(events); in selectObjectContent_canUnmarshallAllEvents()
19 fun testHandler() { in <lambda>() method in kotlinx.coroutines.JobTest
699 public void testHandler() throws Exception { in testHandler() method in JvstTest