42434445464748
public ObjectConnection getConnection() { return client.getConnection(); } public void stop() { new CompositeStoppable(client, connector, executorFactory).stop(); }
179180181182183184185186187
boolean stopped = finished.awaitStop(); if (!stopped) { LOGGER.lifecycle("Time-out waiting for requests. Stopping."); } new CompositeStoppable(incomingConnector, executorFactory).stop(); getRegistryFile().delete(); }
70717273747576777879
processor.processTestClass(testClass); } public void stop() { try { new CompositeStoppable(processors).add(actors).add(resultProcessorActor).stop(); } catch (DispatchException e) { throw UncheckedException.asUncheckedException(e.getCause()); } }