Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for closedasync (0.19 sec)

  1. test/closedchan.go

    		println("testasync2: Nbrecv did not get 1, true, true:", x, ok, selected, c.Impl())
    		failed = true
    	}
    	test1(c)
    }
    
    func closedsync() chan int {
    	c := make(chan int)
    	close(c)
    	return c
    }
    
    func closedasync() chan int {
    	c := make(chan int, 2)
    	c <- 1
    	close(c)
    	return c
    }
    
    var mks = []func(chan int) Chan {
    	func(c chan int) Chan { return XChan(c) },
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Feb 17 04:48:57 UTC 2012
    - 5.8K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java

        }
        valueAndCloser.closeAsync();
      }
    
      @Override
      void assertBecomesCanceled(ClosingFuture<?> closingFuture) throws ExecutionException {
        assertThatFutureBecomesCancelled(closingFuture.statusFuture());
      }
    
      @Override
      void waitUntilClosed(ClosingFuture<?> closingFuture) {
        if (valueAndCloser != null) {
          valueAndCloser.closeAsync();
        }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java

        }
        valueAndCloser.closeAsync();
      }
    
      @Override
      void assertBecomesCanceled(ClosingFuture<?> closingFuture) throws ExecutionException {
        assertThatFutureBecomesCancelled(closingFuture.statusFuture());
      }
    
      @Override
      void waitUntilClosed(ClosingFuture<?> closingFuture) {
        if (valueAndCloser != null) {
          valueAndCloser.closeAsync();
        }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/ClosingFuture.java

     *   // do something with userName
     * } finally {
     *   userNameValueAndCloser.closeAsync();
     * }
     * }</pre>
     *
     * In this example, when {@code userNameValueAndCloser.closeAsync()} is called, the transaction and
     * the query result cursor will both be closed, even if the operation is cancelled or fails.
     *
     * <p>Note that if you don't call {@code closeAsync()}, the captured objects will not be closed. The
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 98.7K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

     *   // do something with userName
     * } finally {
     *   userNameValueAndCloser.closeAsync();
     * }
     * }</pre>
     *
     * In this example, when {@code userNameValueAndCloser.closeAsync()} is called, the transaction and
     * the query result cursor will both be closed, even if the operation is cancelled or fails.
     *
     * <p>Note that if you don't call {@code closeAsync()}, the captured objects will not be closed. The
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 07 12:37:15 UTC 2024
    - 98.3K bytes
    - Viewed (0)
Back to top