Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 609 for await (0.05 sec)

  1. okhttp/src/test/java/okhttp3/EventListenerTest.kt

              call: Call,
              response: Response,
            ) {
              response.close()
              completionLatch.countDown()
            }
          }
        call.enqueue(callback)
        completionLatch.await()
        assertThat(listener.recordedEventTypes()).containsExactly(
          "CallStart",
          "ProxySelectStart", "ProxySelectEnd", "DnsStart", "DnsEnd",
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 56.9K bytes
    - Viewed (2)
  2. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       *   <li>calls {@link ExecutorService#shutdown()}, disabling acceptance of new submitted tasks.
       *   <li>awaits executor service termination for half of the specified timeout.
       *   <li>if the timeout expires, it calls {@link ExecutorService#shutdownNow()}, cancelling
       *       pending tasks and interrupting running tasks.
       *   <li>awaits executor service termination for the other half of the specified timeout.
       * </ol>
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/informers_test.go

    			label.IoIstioDataplaneMode.Name, constants.DataplaneModeAmbient)), metav1.PatchOptions{})
    	assert.NoError(t, err)
    
    	// wait for an update event
    	mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(2))
    
    	// wait for the pod to be annotated
    	// after Pod annotated, another update event will be triggered.
    	assertPodAnnotated(t, client, pod)
    
    	// Assert expected calls actually made
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  4. internal/ioutil/wait_pipe.go

    	})
    	return err
    }
    
    // PipeReader is similar to io.PipeReader with wait group
    type PipeReader struct {
    	*io.PipeReader
    	wait func()
    }
    
    // CloseWithError close with supplied error the reader end
    func (r *PipeReader) CloseWithError(err error) error {
    	err = r.PipeReader.CloseWithError(err)
    	r.wait()
    	return err
    }
    
    // WaitPipe implements wait-group backend io.Pipe to provide
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 27 14:55:36 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  5. cmd/peer-s3-server.go

    					return serr
    				}
    
    				beforeState[index] = madmin.DriveStateMissing
    				afterState[index] = madmin.DriveStateMissing
    
    				return serr
    			}
    			return nil
    		}, index)
    	}
    
    	errs := g.Wait()
    
    	// Initialize heal result info
    	res = madmin.HealResultItem{
    		Type:      madmin.HealItemBucket,
    		Bucket:    bucket,
    		DiskCount: len(localDrives),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  6. internal/config/batch/batch.go

    	config.KV{
    		Key:   ReplicationWorkersWait,
    		Value: "0ms", // No wait by default between each replication attempts.
    	},
    	config.KV{
    		Key:   KeyRotationWorkersWait,
    		Value: "0ms", // No wait by default between each key rotation attempts.
    	},
    	config.KV{
    		Key:   ExpirationWorkersWait,
    		Value: "0ms", // No wait by default between each expiration attempts.
    	},
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. cmd/notification.go

    	if g != nil {
    		g.retryCount = retryCount
    	}
    	return g
    }
    
    // Wait blocks until all function calls from the Go method have returned, then
    // returns the slice of errors from all function calls.
    func (g *NotificationGroup) Wait() []NotificationPeerErr {
    	g.workers.Wait()
    	return g.errs
    }
    
    // Go calls the given function in a new goroutine.
    //
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  8. src/main/java/jcifs/util/transport/Transport.java

                            continue;
                        }
    
                        curResp.wait();
                        if ( handleIntermediate(request, curResp) ) {
                            continue;
                        }
                        if ( log.isDebugEnabled() ) {
                            log.debug("Wait returned state is " + this.state);
                        }
                        if ( isDisconnected() ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 01 18:12:21 UTC 2020
    - 24.1K bytes
    - Viewed (0)
  9. src/main/java/jcifs/FileNotifyInformation.java

         * Any file name change in the watched directory or subtree causes a change notification wait operation to return.
         * Changes include renaming, creating, or deleting a file.
         */
        public static final int FILE_NOTIFY_CHANGE_FILE_NAME = 0x00000001;
    
        /**
         * Any directory-name change in the watched directory or subtree causes a change notification wait operation to
         * return. Changes include creating or deleting a directory.
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 4.9K bytes
    - Viewed (0)
  10. ci/devinfra/docker/windows/Dockerfile

             'msys2.tar.xz'); \
        Start-Process -FilePath \"C:\Program Files\7-Zip\7z.exe\" -ArgumentList 'x msys2.tar.xz -oC:\TEMP\msys2.tar' -Wait; \
        Start-Process -FilePath \"C:\Program Files\7-Zip\7z.exe\" -ArgumentList 'x C:\TEMP\msys2.tar -oC:\tools' -Wait; \
        $env:PATH = [Environment]::GetEnvironmentVariable('PATH', 'Machine') + ';C:\tools\msys64;C:\tools\msys64\usr\bin\'; \
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Aug 20 13:57:04 UTC 2024
    - 7.3K bytes
    - Viewed (0)
Back to top