Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 631 for Closer (0.25 seconds)

  1. android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java

            .isTrue();
      }
    
      public void testFinishToValueAndCloser_throwsIfCalledTwice() throws Exception {
        ClosingFuture<Closeable> closingFuture =
            ClosingFuture.submit(closer -> closer.eventuallyClose(mockCloseable, executor), executor);
        closingFuture.finishToValueAndCloser(
            new NoOpValueAndCloserConsumer<>(), finishToValueAndCloserExecutor);
        assertThrows(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 5.2K bytes
    - Click Count (0)
  2. okhttp/src/androidMain/kotlin/okhttp3/internal/platform/Android10Platform.kt

        socketAdapters.find { it.matchesSocket(sslSocket) }?.getSelectedProtocol(sslSocket)
    
      override fun getStackTraceForCloseable(closer: String): Any? =
        if (Build.VERSION.SDK_INT >= 30) {
          CloseGuard().apply { open(closer) }
        } else {
          super.getStackTraceForCloseable(closer)
        }
    
      override fun logCloseableLeak(
        message: String,
        stackTrace: Any?,
      ) {
        if (Build.VERSION.SDK_INT >= 30) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jul 20 11:25:50 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToFutureTest.java

    public class ClosingFutureFinishToFutureTest extends AbstractClosingFutureTest {
      public void testFinishToFuture_throwsIfCalledTwice() throws Exception {
        ClosingFuture<Closeable> closingFuture =
            ClosingFuture.submit(closer -> closer.eventuallyClose(mockCloseable, executor), executor);
        FluentFuture<Closeable> unused = closingFuture.finishToFuture();
        assertThrows(
            IllegalStateException.class,
            () -> {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/math/ToDoubleRounder.java

              X deltaToCeiling = minus(roundCeiling, x);
              int diff = deltaToFloor.compareTo(deltaToCeiling);
              if (diff < 0) { // closer to floor
                return roundFloorAsDouble;
              } else if (diff > 0) { // closer to ceiling
                return roundCeilingAsDouble;
              }
              // halfway between the representable values; do the half-whatever logic
              switch (mode) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 03 04:51:56 GMT 2026
    - 5.7K bytes
    - Click Count (0)
  5. internal/lock/lock.go

    	r.mutex.Lock()
    	r.refs++
    	r.mutex.Unlock()
    }
    
    // Close - this closer implements a special closer
    // closes the underlying fd only when the refs
    // reach zero.
    func (r *RLockedFile) Close() (err error) {
    	r.mutex.Lock()
    	defer r.mutex.Unlock()
    
    	if r.refs == 0 {
    		return os.ErrInvalid
    	}
    
    	r.refs--
    	if r.refs == 0 {
    		err = r.File.Close()
    	}
    
    	return err
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 2.5K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToFutureTest.java

    public class ClosingFutureFinishToFutureTest extends AbstractClosingFutureTest {
      public void testFinishToFuture_throwsIfCalledTwice() throws Exception {
        ClosingFuture<Closeable> closingFuture =
            ClosingFuture.submit(closer -> closer.eventuallyClose(mockCloseable, executor), executor);
        FluentFuture<Closeable> unused = closingFuture.finishToFuture();
        assertThrows(
            IllegalStateException.class,
            () -> {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java

            .isTrue();
      }
    
      public void testFinishToValueAndCloser_throwsIfCalledTwice() throws Exception {
        ClosingFuture<Closeable> closingFuture =
            ClosingFuture.submit(closer -> closer.eventuallyClose(mockCloseable, executor), executor);
        closingFuture.finishToValueAndCloser(
            new NoOpValueAndCloserConsumer<>(), finishToValueAndCloserExecutor);
        assertThrows(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 5.2K bytes
    - Click Count (0)
  8. compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/DefaultGraphConflictResolutionPolicy.java

    /**
     *
     */
    @Named
    @Singleton
    @Deprecated
    public class DefaultGraphConflictResolutionPolicy implements GraphConflictResolutionPolicy {
        /**
         * artifact, closer to the entry point, is selected
         */
        @Configuration(name = "closer-first", value = "true")
        private boolean closerFirst = true;
    
        /**
         * newer artifact is selected
         */
        @Configuration(name = "newer-first", value = "true")
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureLeakTest.java

      }
    
      private WeakReference<ClosingFuture<String>> leakClosingFuture(TestCloseable closeable) {
        ClosingFuture<String> willCloseCloseable =
            ClosingFuture.submit(
                closer -> {
                  closer.eventuallyClose(closeable, directExecutor());
                  return "";
                },
                directExecutor());
        return new WeakReference<>(willCloseCloseable);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 1.8K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/ClosingFutureLeakTest.java

      }
    
      private WeakReference<ClosingFuture<String>> leakClosingFuture(TestCloseable closeable) {
        ClosingFuture<String> willCloseCloseable =
            ClosingFuture.submit(
                closer -> {
                  closer.eventuallyClose(closeable, directExecutor());
                  return "";
                },
                directExecutor());
        return new WeakReference<>(willCloseCloseable);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 1.8K bytes
    - Click Count (0)
Back to Top