Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 385 for cancels (0.06 sec)

  1. guava/src/com/google/common/base/Ascii.java

       * structure is not necessarily related to the processing format.
       *
       * @since 8.0
       */
      public static final byte ETB = 23;
    
      /**
       * Cancel: A control character used to indicate that the data with which it is sent is in error or
       * is to be disregarded.
       *
       * @since 8.0
       */
      public static final byte CAN = 24;
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 13:50:22 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  2. docs/pt/docs/async.md

    Ainda, em ambas as situações, as chances são que o **FastAPI** será [ainda mais rápido](index.md#performance){.internal-link target=_blank} do que (ou ao menos comparável a) seus frameworks antecessores.
    
    ### Dependências
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  3. cmd/server_test.go

    }
    
    func (s *TestSuiteCommon) RestartTestServer(c *check) {
    	// Shutdown.
    	s.testServer.cancel()
    	s.testServer.Server.Close()
    	s.testServer.Obj.Shutdown(context.Background())
    
    	// Restart.
    	ctx, cancel := context.WithCancel(context.Background())
    
    	s.testServer.cancel = cancel
    	s.testServer = initTestServerWithBackend(ctx, c, s.testServer, s.testServer.Obj, s.testServer.rawDiskPaths)
    	if s.secure {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 116.3K bytes
    - Viewed (0)
  4. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

        val connectionClose = CountDownLatch(1)
        val streams =
          object : RealWebSocket.Streams(false, source, sink) {
            override fun close() = connectionClose.countDown()
    
            override fun cancel() {
              socket.closeQuietly()
            }
          }
        val webSocket =
          RealWebSocket(
            taskRunner = taskRunner,
            originalRequest = fancyRequest,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  5. cmd/common-main.go

    	// syscall.SIGHUP to reload the certs.
    	manager.ReloadOnSignal(syscall.SIGHUP)
    
    	return x509Certs, manager, secureConn, nil
    }
    
    // contextCanceled returns whether a context is canceled.
    func contextCanceled(ctx context.Context) bool {
    	select {
    	case <-ctx.Done():
    		return true
    	default:
    		return false
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  6. doc/godebug.md

    For Go 1.24, it now defaults to multipathtcp="2", thus
    enabled by default on listerners. Using multipathtcp="0" reverts to the
    pre-Go 1.24 behavior.
    
    ### Go 1.23
    
    Go 1.23 changed the channels created by package time to be unbuffered
    (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop)
    and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 28 14:46:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

        try {
          future.get(timeoutMillis, MILLISECONDS);
          shouldThrow();
        } catch (TimeoutException success) {
        } catch (Exception e) {
          threadUnexpectedException(e);
        } finally {
          future.cancel(true);
        }
        assertTrue(millisElapsedSince(startTime) >= timeoutMillis);
      }
    
      /** Fails with message "should throw exception". */
      public void shouldThrow() {
        fail("Should throw exception");
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  8. tensorflow/c/eager/c_api_experimental.h

    TF_CAPI_EXPORT extern void TFE_DeleteCancellationManager(
        TFE_CancellationManager*);
    
    // Associates the given `cancellation_manager` with `op`, so that invoking
    // `TFE_CancellationManagerStartCancel(cancellation_manager)` will cancel the
    // execution of `op`.
    typedef struct TFE_CancellationManager TFE_CancellationManager;
    TF_CAPI_EXPORT extern void TFE_OpSetCancellationManager(
        TFE_Op* op, TFE_CancellationManager* cancellation_manager,
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Feb 21 22:37:46 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

        try {
          future.get(timeoutMillis, MILLISECONDS);
          shouldThrow();
        } catch (TimeoutException success) {
        } catch (Exception e) {
          threadUnexpectedException(e);
        } finally {
          future.cancel(true);
        }
        assertTrue(millisElapsedSince(startTime) >= timeoutMillis);
      }
    
      /** Fails with message "should throw exception". */
      public void shouldThrow() {
        fail("Should throw exception");
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  10. internal/ringbuffer/ring_buffer_test.go

    		} else {
    			t.Log("ok")
    		}
    	}
    	result := string(buf[0:n])
    	if result != "hello" {
    		t.Errorf("got: %q; want: %q", result, "hello")
    	}
    }
    
    func timeout(after time.Duration) (cancel func()) {
    	c := time.After(after)
    	cc := make(chan struct{})
    	go func() {
    		select {
    		case <-cc:
    			return
    		case <-c:
    			buf := make([]byte, 1<<20)
    			stacklen := runtime.Stack(buf, true)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
Back to top