Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 471 - 480 of 584 for invokers (0.05 seconds)

  1. src/test/java/jcifs/smb/SmbRenewableCredentialsTest.java

            // Arrange: stub renew() to return a mocked CredentialsInternal
            when(renewable.renew()).thenReturn(returned);
    
            // Act: invoke renew()
            CredentialsInternal result = renewable.renew();
    
            // Assert: verify interaction and returned value
            verify(renewable, times(1)).renew();
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 7K bytes
    - Click Count (0)
  2. internal/stmt_store/stmt_store.go

    //   - ttl: The time-to-live duration for each cache entry. If the provided ttl is less than or equal to 0,
    //     it defaults to defaultTTL.
    //
    // This function defines an onEvicted callback that is invoked when a cache entry is evicted.
    // The callback ensures that if the evicted value (v) is not nil, its Close method is called asynchronously
    // to release associated resources.
    //
    // Returns:
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun Apr 27 06:05:16 GMT 2025
    - 6K bytes
    - Click Count (0)
  3. guava/src/com/google/common/cache/CacheBuilder.java

       * value. Note that multiple threads can concurrently load values for distinct keys.
       *
       * <p>This method does not alter the state of this {@code CacheBuilder} instance, so it can be
       * invoked again to create multiple independent caches.
       *
       * @param loader the cache loader used to obtain new values
       * @return a cache having the requested features
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 51.6K bytes
    - Click Count (0)
  4. guava/src/com/google/common/reflect/Types.java

        TypeVariableInvocationHandler(TypeVariableImpl<?> typeVariableImpl) {
          this.typeVariableImpl = typeVariableImpl;
        }
    
        @Override
        public @Nullable Object invoke(Object proxy, Method method, @Nullable Object @Nullable [] args)
            throws Throwable {
          String methodName = method.getName();
          Method typeVariableMethod = typeVariableMethods.get(methodName);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Oct 31 19:34:24 GMT 2025
    - 24.3K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java

        assertThat(sepLoader).isSameInstanceAs(sepStopwatchC.getClassLoader());
        AtomicReference<Object> sepStopwatchA =
            new AtomicReference<Object>(sepStopwatchC.getMethod("createUnstarted").invoke(null));
        AtomicReference<WeakReference<?>> sepStopwatchRef =
            new AtomicReference<WeakReference<?>>(
                (WeakReference<?>) sepFwrCons.newInstance(sepStopwatchA.get(), sepFrqA.get()));
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 7.6K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

          lastMethodCalled = "invokeAllTimeout";
          lastTimeoutInMillis = unit.toMillis(timeout);
          return inline.invokeAll(tasks, timeout, unit);
        }
    
        // Define the invokeAny methods to invoke the first task
        @Override
        public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
            throws ExecutionException, InterruptedException {
          assertTaskWrapped(tasks);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Jul 14 14:44:08 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/reflect/SubtypeTester.java

          if (method.isAnnotationPresent(TestSubtype.class)) {
            method.setAccessible(true);
            SubtypeTester tester = (SubtypeTester) clone();
            tester.method = method;
            method.invoke(tester, new Object[] {null});
          }
        }
      }
    
      private Type getOnlyParameterType() {
        assertThat(method.getGenericParameterTypes()).hasLength(1);
        return method.getGenericParameterTypes()[0];
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Nov 25 23:29:58 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

          throw new RuntimeException("I bet you didn't think Thread.interrupt could throw");
        }
    
        void doBegin() {
          super.begin();
        }
      }
    
      /**
       * Because Thread.interrupt() can invoke arbitrary code, it can be slow (e.g. perform IO). To
       * protect ourselves from that we want to make sure that tasks don't spin too much waiting for the
       * interrupting thread to complete the protocol.
       */
      /*
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/hash/AbstractStreamingHasher.java

        this.chunkSize = chunkSize;
      }
    
      /** Processes the available bytes of the buffer (at most {@code chunk} bytes). */
      protected abstract void process(ByteBuffer bb);
    
      /**
       * This is invoked for the last bytes of the input, which are not enough to fill a whole chunk.
       * The passed {@code ByteBuffer} is guaranteed to be non-empty.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 7.1K bytes
    - Click Count (0)
  10. docs/lambda/README.md

    EOF
    ```
    
    Upload this object to the bucket via `mc cp`
    ```
    mc cp testobject myminio/functionbucket/
    ```
    
    ## Invoke Lambda transformation via PresignedGET
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 7.7K bytes
    - Click Count (0)
Back to Top