Searched refs:terminationFuture (Results 1 – 17 of 17) sorted by relevance
26 private val terminationFuture = ResolvableFuture.create<Void>() constant57 terminationFuture.set(null) in isEndOfStream()66 terminationFuture.set(null) in cancel()73 return terminationFuture in getTerminationFuture()77 check(!terminationFuture.isDone) in throwIfTerminated()
27 private val terminationFuture = ResolvableFuture.create<Void>() constant50 terminationFuture.set(null) in close()54 return terminationFuture in getClosedFuture()
197 reprocDeferrableSurface.terminationFuture.addListener( in addZslConfig()264 reprocImageDeferrableSurface.terminationFuture.addListener( in reset()
46 inputBuffer.terminationFuture.addListener( in acquireBuffer()
262 ListenableFuture<Void> terminationFuture = in SurfaceRequest() local272 Futures.propagate(terminationFuture, sessionStatusCompleter); in SurfaceRequest()297 terminationFuture.addListener(() -> mSurfaceFuture.cancel(true), in SurfaceRequest()
733 outputSurface.terminationFuture.addListener( in outputSurfaceTerminatedProperly()774 outputSurface.terminationFuture.addListener( in <lambda>()932 previewOutputDeferrableSurface.terminationFuture.addListener(951 captureOutputDeferrableSurface.terminationFuture.addListener(
312 terminationFuture.addListener( in <lambda>()345 terminationFuture.addListener( in <lambda>()
130 previewSurface.terminationFuture.addListener( in setUp()152 captureSurface.terminationFuture.addListener( in setUp()
153 previewProcessorSurface.terminationFuture.addListener( in <lambda>()200 captureProcessorSurface.terminationFuture.addListener( in <lambda>()
172 it.terminationFuture.addListener({ it.cleanUp() }, MoreExecutors.directExecutor()) in <lambda>()
215 terminationFuture.addListener({ cleanUp() }, Dispatchers.IO.asExecutor()) in <lambda>()
580 terminationFuture.addListener({ cleanUp() }, Dispatchers.IO.asExecutor()) in <lambda>()
114 .terminationFuture in <lambda>()
220 .terminationFuture in <lambda>()
232 terminationFuture.addListener({ cleanUp() }, testDispatcher.asExecutor()) in <lambda>()
1003 terminationFuture.addListener({ cleanUp() }, useCaseThreads.backgroundExecutor) in <lambda>()1012 terminationFuture.addListener({ cleanUp() }, useCaseThreads.backgroundExecutor) in <lambda>()
445 it.terminationFuture.addListener({ it.cleanUp() }, useCaseThreads.backgroundExecutor) in createTestDeferrableSurface()