- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 503 for Rangel (0.23 sec)
-
internal/grid/muxserver.go
ctx, cancel = context.WithTimeout(ctx, time.Duration(msg.DeadlineMS)*time.Millisecond) } else { ctx, cancel = context.WithCancel(ctx) } m := muxServer{ ID: msg.MuxID, RecvSeq: msg.Seq + 1, SendSeq: msg.Seq, ctx: ctx, cancel: cancel, parent: c, LastPing: time.Now().Unix(), BaseFlags: c.baseFlags, } go func() { // TODO: Handle }() return &m }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
docs/en/data/external_links.yml
title: フロントエンド開発者向けのDockerによるPython開発環境構築 - author: '@angel_katayoku' author_link: https://qiita.com/angel_katayoku link: https://qiita.com/angel_katayoku/items/8a458a8952f50b73f420 title: FastAPIでPOSTされたJSONのレスポンスbodyを受け取る - author: '@angel_katayoku' author_link: https://qiita.com/angel_katayoku link: https://qiita.com/angel_katayoku/items/4fbc1a4e2b33fa2237d2 title: FastAPIをMySQLと接続してDockerで管理してみる
Others - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Mar 21 20:57:27 GMT 2024 - 21.3K bytes - Viewed (2) -
guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java
async.setFuture(inner); async.cancel(false); assertTrue(inner.isCancelled()); assertFalse(inner.wasInterrupted()); assertThrows(CancellationException.class, () -> inner.get()); } public void testCancel_beforeSet() throws Exception { SettableFuture<Object> async = SettableFuture.create(); async.cancel(true); assertFalse(async.set(42)); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 7.3K bytes - Viewed (1) -
android/guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java
async.setFuture(inner); async.cancel(false); assertTrue(inner.isCancelled()); assertFalse(inner.wasInterrupted()); assertThrows(CancellationException.class, () -> inner.get()); } public void testCancel_beforeSet() throws Exception { SettableFuture<Object> async = SettableFuture.create(); async.cancel(true); assertFalse(async.set(42)); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 7.3K bytes - Viewed (0) -
internal/config/dns/etcd_dns.go
cancel() if err != nil { ctx, cancel = context.WithTimeout(context.Background(), defaultContextTimeout) c.etcdClient.Delete(ctx, key) cancel() return err } } } return nil } // Delete - Removes DNS entries added in Put(). func (c *CoreDNS) Delete(bucket string) error { for _, domainName := range c.domainNames {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 8.3K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
optionalDeleteCmds := [][]string{ // flush-then-delete our created chains {"-t", iptablesconstants.MANGLE, "-F", ChainInpodPrerouting}, {"-t", iptablesconstants.MANGLE, "-F", ChainInpodOutput}, {"-t", iptablesconstants.NAT, "-F", ChainInpodOutput}, {"-t", iptablesconstants.MANGLE, "-X", ChainInpodPrerouting}, {"-t", iptablesconstants.MANGLE, "-X", ChainInpodOutput}, {"-t", iptablesconstants.NAT, "-X", ChainInpodOutput}, }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 19.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
inputFuture.cancel(true); // argument is ignored assertThrows(CancellationException.class, () -> resultFuture.get()); } public void testFutureGetThrowsCancellationIfOutputCancelled() throws Exception { inputFuture.set(SLOW_OUTPUT_VALID_INPUT_DATA); outputFuture.cancel(true); // argument is ignored
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.1K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt
get().log("[ES] onFailure", Platform.INFO, t) events.add(Failure(t, response)) drainCancelQueue(eventSource) } private fun drainCancelQueue(eventSource: EventSource) { if (cancel) { cancel = false eventSource.cancel() } } private fun nextEvent(): Any { return events.poll(10, TimeUnit.SECONDS) ?: throw AssertionError("Timed out waiting for event.") }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
this.lock = lock; this.currentFuture = currentFuture; } @Override public void cancel(boolean mayInterruptIfRunning) { /* * Lock to ensure that a task cannot be rescheduled while a cancel is ongoing. * * In theory, cancel() could execute arbitrary listeners -- bad to do while holding a lock.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 25.8K bytes - Viewed (0) -
cni/cmd/install-cni/main.go
func main() { // Create context that cancels on termination signal ctx, cancel := context.WithCancel(context.Background()) sigChan := make(chan os.Signal, 1) signal.Notify(sigChan, os.Interrupt, syscall.SIGTERM) go func(sigChan chan os.Signal, cancel context.CancelFunc) { sig := <-sigChan log.Infof("Exit signal received: %s", sig) cancel() }(sigChan, cancel) rootCmd := cmd.GetCommand()
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue May 23 17:08:31 GMT 2023 - 1.2K bytes - Viewed (0)