Home
last modified time | relevance | path

Searched refs:futureTask (Results 1 – 4 of 4) sorted by relevance

/room/integration-tests/testapp/src/androidTest/java/androidx/room/integration/testapp/test/
DTestUtil.java138 FutureTask<Void> futureTask = new FutureTask<>(() -> { in observeOnMainThread() local
142 ArchTaskExecutor.getInstance().executeOnMainThread(futureTask); in observeOnMainThread()
143 futureTask.get(); in observeOnMainThread()
149 FutureTask<Void> futureTask = new FutureTask<>(() -> { in observeForeverOnMainThread() local
153 ArchTaskExecutor.getInstance().executeOnMainThread(futureTask); in observeForeverOnMainThread()
154 futureTask.get(); in observeForeverOnMainThread()
DQueryTransactionTest.java348 FutureTask<Void> futureTask = new FutureTask<>(() -> { in observeForever() local
353 ArchTaskExecutor.getMainThreadExecutor().execute(futureTask); in observeForever()
355 futureTask.get(); in observeForever()
/room/integration-tests/kotlintestapp/src/androidTest/java/androidx/room/integration/kotlintestapp/test/
DTestUtil.kt41 val futureTask = FutureTask { liveData.observe(provider, observer) } in observeOnMainThread() constant
42 ArchTaskExecutor.getInstance().executeOnMainThread(futureTask) in observeOnMainThread()
43 futureTask.get() in observeOnMainThread()
/room/integration-tests/testapp/src/androidTest/java/androidx/room/integration/testapp/paging/
DDataSourceFactoryTest.java164 FutureTask<Void> futureTask = new FutureTask<>(() -> { in observe() local
168 ArchTaskExecutor.getInstance().executeOnMainThread(futureTask); in observe()
169 futureTask.get(); in observe()