Searched refs:joinReceiver (Results 1 – 9 of 9) sorted by relevance
84 receiver.joinReceiver(500); in testPrintEvent_printToSocket()117 receiver.joinReceiver(500); in testPrintEvent_legacyMethodCalls()
131 receiver.joinReceiver(LONG_TIMEOUT_MS); in testPrintEvent_printToSocket()183 receiver.joinReceiver(LONG_TIMEOUT_MS); in testPrintEvent_printToSocket_StructuredFailures()240 receiver.joinReceiver(LONG_TIMEOUT_MS); in testTestLog()268 receiver.joinReceiver(500); in testTestLog_disabled()
119 receiver.joinReceiver(5000); in testStream()176 receiver.joinReceiver(100); in testStream_stopParsing()230 receiver.joinReceiver(5000); in testStream_noInvocationReporting()
303 assertTrue(resultParser.joinReceiver(500)); in testParser_receiveFromSocket()330 assertFalse(resultParser.joinReceiver(50)); in testParser_failToJoin()344 assertTrue(parser.joinReceiver(50, false)); in testParser_noConnection()
224 public boolean joinReceiver(long millis) { in joinReceiver() method in StreamProtoReceiver
414 if (!eventParser.joinReceiver(EVENT_THREAD_JOIN_TIMEOUT_MS)) { in run()422 if (!protoReceiver.joinReceiver(EVENT_THREAD_JOIN_TIMEOUT_MS)) { in run()
206 public boolean joinReceiver(long millis) { in joinReceiver() method in SubprocessTestResultsParser207 return joinReceiver(millis, true); in joinReceiver()217 public boolean joinReceiver(long millis, boolean waitForConnection) { in joinReceiver() method in SubprocessTestResultsParser
235 joinResult = mProtoReceiver.joinReceiver(waitTime); in run()237 joinResult = mEventParser.joinReceiver(waitTime); in run()
242 subprocessEventParser.joinReceiver( in run()