Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for transaction (0.45 sec)

  1. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

     *         .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor)
     *         .transform((closer, result) -> result.get("userName"), directExecutor())
     *         .catching(DBException.class, e -> "no user", directExecutor())
     *         .finishToFuture();
     * }</pre>
     *
     * In this example, when the {@code userName} {@link Future} is done, the transaction and the query
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 98.5K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/ServiceTest.java

    public class ServiceTest extends TestCase {
    
      /** Assert on the comparison ordering of the State enum since we guarantee it. */
      public void testStateOrdering() {
        // List every valid (direct) state transition.
        assertLessThan(NEW, STARTING);
        assertLessThan(NEW, TERMINATED);
    
        assertLessThan(STARTING, RUNNING);
        assertLessThan(STARTING, STOPPING);
        assertLessThan(STARTING, FAILED);
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 1.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/net/InetAddresses.java

     * were never supposed to be seen on the wire. That assumption was dropped, some say mistakenly, in
     * later RFCs with the apparent aim of making IPv4-to-IPv6 transition simpler.
     *
     * <p>Technically one <i>can</i> create a 128bit IPv6 address with the wire format of a "mapped"
     * address, as shown above, and transmit it in an IPv6 packet header. However, Java's InetAddress
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Dec 15 19:31:54 GMT 2023
    - 44K bytes
    - Viewed (1)
  4. guava/src/com/google/common/base/Functions.java

       * future, when this class requires Java 8, this method will be deprecated. See {@link Function}
       * for more important information about the Java 8+ transition.
       */
      public static Function<Object, String> toStringFunction() {
        return ToStringFunction.INSTANCE;
      }
    
      // enum singleton pattern
      private enum ToStringFunction implements Function<Object, String> {
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 15 16:12:13 GMT 2024
    - 14.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Service.java

       *
       * <p>The ordering of the {@link State} enum is defined such that if there is a state transition
       * from {@code A -> B} then {@code A.compareTo(B) < 0}. N.B. The converse is not true, i.e. if
       * {@code A.compareTo(B) < 0} then there is <b>not</b> guaranteed to be a valid state transition
       * {@code A -> B}.
       *
       * @since 9.0 (in 1.0 as {@code com.google.common.base.Service.State})
       */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 10.7K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java

      // test without that cast to verify that using the raw Comparable works outside J2KT.
      @J2ktIncompatible // J2KT's translation of raw Comparable is not a supertype of Int translation
      public void testCreation_expectedSize() {
        MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue.expectedSize(8).create();
        assertEquals(8, queue.capacity());
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Mar 07 18:34:03 GMT 2024
    - 36.1K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

          }
    
          /** Transition to the COMPLETED state and set the value. */
          boolean set(@Nullable V v) {
            return complete(v, null, COMPLETED);
          }
    
          /** Transition to the COMPLETED state and set the exception. */
          boolean setException(Throwable t) {
            return complete(null, t, COMPLETED);
          }
    
          /** Transition to the CANCELLED or INTERRUPTED state. */
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed May 09 15:17:25 GMT 2018
    - 13.6K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

          }
    
          /** Transition to the COMPLETED state and set the value. */
          boolean set(@Nullable V v) {
            return complete(v, null, COMPLETED);
          }
    
          /** Transition to the COMPLETED state and set the exception. */
          boolean setException(Throwable t) {
            return complete(null, t, COMPLETED);
          }
    
          /** Transition to the CANCELLED or INTERRUPTED state. */
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Apr 06 12:56:11 GMT 2023
    - 13.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

         * correctly installed
         *
         * <p>{@link #transitioned}: is set by {@link #transitionService} to indicate that some
         * transition has been performed.
         *
         * <p>Together, they allow us to enforce that all services have their listeners installed prior
         * to any service performing a transition, then we can fail in the ServiceManager constructor
         * rather than in a Service.Listener callback.
         */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 30.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/AbstractService.java

        }
    
        @Override
        public boolean isSatisfied() {
          return state().compareTo(TERMINATED) >= 0;
        }
      }
    
      /** The listeners to notify during a state transition. */
      private final ListenerCallQueue<Listener> listeners = new ListenerCallQueue<>();
    
      /**
       * The current state of the service. This should be written with the lock held but can be read
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri May 12 18:32:03 GMT 2023
    - 20.4K bytes
    - Viewed (0)
Back to top