Lines Matching refs:service
34 import com.google.common.util.concurrent.Service.Listener;
35 import com.google.common.util.concurrent.Service.State;
73 private StreamService service;
86 if (service != null && service.state() != State.FAILED && service.state() != State.TERMINATED) {
87 service.stopAsync().awaitTerminated();
93 service.startAsync().awaitRunning();
102 assertEquals(State.RUNNING, service.state());
111 service.startAsync().awaitRunning();
114 assertEquals(State.FAILED, service.state());
120 service.startAsync().awaitRunning();
123 assertEquals(State.FAILED, service.state());
131 service.startAsync().awaitRunning();
133 service.sendMessage(new DummyLogMessage("hello socket world"));
135 service.closeWriter();
136 assertEquals(State.RUNNING, service.state());
147 service.startAsync().awaitRunning();
149 service.sendMessage(new DummyLogMessage("hello socket world"));
151 service.closeWriter();
155 assertEquals(State.RUNNING, service.state());
165 service.startAsync().awaitRunning();
168 assertEquals(SocketException.class, service.failureCause().getClass());
173 StreamItem item = service.readItem(10, TimeUnit.SECONDS);
179 * Wait for the service to reach a terminal state without calling stop.
186 State state = service.state();
189 throw new AssertionError(service.failureCause());
191 fail("Expected service to be terminated but was: " + state);
197 checkState(service == null, "You can only make one StreamService per test");
217 service = new StreamService(
224 service.addListener(new Listener() {
