HomeSort by relevance Sort by last modified time
    Searched refs:StreamService (Results 1 - 8 of 8) sorted by null

  /packages/apps/Car/Stream/src/com/android/car/stream/
StreamProducer.java 31 * A base class that produces {@link StreamCard} for the StreamService
40 * has connected to the {@link StreamService}. After connecting, these cards are posted to
41 * the StreamService.
45 private StreamService mStreamService;
52 * Posts the given card to the {@link StreamService} for rendering by stream consumers.
55 * {@link StreamService} is not available. The given card will be queued and posted when the
56 * {@link StreamService} becomes available.
65 Log.d(TAG, "StreamService not found, adding card to queue for later addition.");
73 * Removes the given card from the {@link StreamService}. If this {@link StreamProducer} has not
74 * connected to the {@link StreamService}, then {@link #mQueuedCards} is checked to see if i
    [all...]
StreamService.java 36 public class StreamService extends Service {
37 private static final String TAG = "StreamService";
49 StreamService getService() {
50 return StreamService.this;
58 + " StreamService process ID: " + android.os.Process.myPid());
117 * Add a {@link StreamCard} to the StreamService. The {@link StreamCard} will be published to
118 * all IStreamListener registered with the StreamService.
130 * Remove a {@link StreamCard} to the StreamService. All registered {@link IStreamConsumer} will
PermissionsActivity.java 79 startService(new Intent(this, StreamService.class));
110 startService(new Intent(this, StreamService.class));
StreamApplication.java 30 * Base application for {@link StreamService}
40 startService(new Intent(this, StreamService.class));
  /external/caliper/caliper/src/main/java/com/google/caliper/runner/
TrialRunLoop.java 26 import com.google.caliper.runner.StreamService.StreamItem;
54 private final StreamService streamService;
69 StreamService streamService,
73 this.streamService = streamService;
80 if (streamService.state() != State.NEW) {
85 streamService.startAsync().awaitRunning();
93 item = streamService.readItem
    [all...]
TrialModule.java 103 static StreamService provideStreamService(
107 return new StreamService(worker, logMessageParser, trialOutput);
StreamService.java 24 import com.google.caliper.runner.StreamService.StreamItem.Kind;
78 @TrialScoped final class StreamService extends AbstractService {
82 private static final Logger logger = Logger.getLogger(StreamService.class.getName());
112 @Inject StreamService(WorkerProcess worker,
195 checkState(isRunning(), "Cannot read items from a %s StreamService", state());
212 checkState(isRunning(), "Cannot read items from a %s StreamService", state());
228 checkState(isRunning(), "Cannot read items from a %s StreamService", state());
  /external/caliper/caliper/src/test/java/com/google/caliper/runner/
StreamServiceTest.java 27 import com.google.caliper.runner.StreamService.StreamItem;
28 import com.google.caliper.runner.StreamService.StreamItem.Kind;
58 * Tests for {@link StreamService}.
73 private StreamService service;
197 checkState(service == null, "You can only make one StreamService per test");
217 service = new StreamService(

Completed in 255 milliseconds