Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 140 for Coroutine (0.04 seconds)

  1. cmd/utils.go

    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerGoroutines:
    		prof.ext = "txt"
    		prof.record("goroutine", 1, "before")
    		prof.record("goroutine", 2, "before,debug=2")
    		prof.stopFn = func() ([]byte, error) {
    			var buf bytes.Buffer
    			err := pprof.Lookup("goroutine").WriteTo(&buf, 1)
    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerTrace:
    		dirPath, err := os.MkdirTemp("", "profile")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  2. cmd/admin-heal-ops.go

    	h.mutex.Unlock()
    
    	return nil
    }
    
    // healSequenceStart - this is the top-level background heal
    // routine. It launches another go-routine that actually traverses
    // on-disk data, checks and heals according to the selected
    // settings. This go-routine itself, (1) monitors the traversal
    // routine for completion, and (2) listens for external stop
    // signals. When either event happens, it sets the finish status for
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  3. okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt

    import kotlinx.coroutines.coroutineScope
    import kotlinx.coroutines.job
    import kotlinx.coroutines.supervisorScope
    import kotlinx.coroutines.test.runTest
    import kotlinx.coroutines.withContext
    import kotlinx.coroutines.withTimeout
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.SocketEffect
    import mockwebserver3.junit5.StartStop
    import okhttp3.Callback
    import okhttp3.FailingCall
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Jun 20 11:46:46 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  4. okhttp-coroutines/build.gradle.kts

      id("binary-compatibility-validator")
    }
    
    project.applyOsgi(
      "Export-Package: okhttp3.coroutines",
      "Bundle-SymbolicName: com.squareup.okhttp3.coroutines"
    )
    
    project.applyJavaModules("okhttp3.coroutines")
    
    dependencies {
      api(projects.okhttp)
      implementation(libs.kotlinx.coroutines.core)
      api(libs.squareup.okio)
      api(libs.kotlin.stdlib)
    
      testImplementation(libs.kotlin.test.annotations)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Sep 21 06:22:22 GMT 2025
    - 937 bytes
    - Click Count (0)
  5. docs/es/docs/async.md

    En versiones previas de NodeJS / JavaScript en el Navegador, habrĂ­as usado "callbacks". Lo que lleva al "callback hell".
    
    ## Coroutines { #coroutines }
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 10:15:01 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  6. okhttp/src/androidMain/baseline-prof.txt

    HSPLkotlin/coroutines/CombinedContext;->plus(Lkotlin/coroutines/CoroutineContext;)Lkotlin/coroutines/CoroutineContext;
    HSPLkotlin/coroutines/ContinuationInterceptor$Key;-><clinit>()V
    HSPLkotlin/coroutines/ContinuationInterceptor$Key;-><init>()V
    HSPLkotlin/coroutines/CoroutineContext$DefaultImpls;->plus(Lkotlin/coroutines/CoroutineContext;Lkotlin/coroutines/CoroutineContext;)Lkotlin/coroutines/CoroutineContext;
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Dec 30 23:28:56 GMT 2024
    - 127.9K bytes
    - Click Count (1)
  7. src/bufio/net_test.go

    		Name: socket,
    		Net:  "unixpacket",
    	}
    	server, err := net.ListenUnix("unixpacket", addr)
    	if err != nil {
    		t.Skipf("skipping test because opening a unixpacket socket failed: %v", err)
    	}
    
    	// Start a goroutine for the server to accept one connection
    	// and read all the data sent on the connection,
    	// reporting the number of bytes read on ch.
    	ch := make(chan int, 1)
    	var wg sync.WaitGroup
    	wg.Add(1)
    	go func() {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Feb 07 19:37:07 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  8. gradle/libs.versions.toml

    kotlin-test-junit = { module = "org.jetbrains.kotlin:kotlin-test-junit", version.ref = "org-jetbrains-kotlin" }
    kotlinx-coroutines-core = { module = "org.jetbrains.kotlinx:kotlinx-coroutines-core", version.ref = "org-jetbrains-coroutines" }
    kotlinx-coroutines-test = { module = "org.jetbrains.kotlinx:kotlinx-coroutines-test", version.ref = "org-jetbrains-coroutines" }
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 19 22:05:50 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  9. okhttp-coroutines/src/main/java9/module-info.java

    @SuppressWarnings("module")
    module okhttp3.coroutines {
      requires okhttp3;
      exports okhttp3.coroutines;
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Sep 21 06:22:22 GMT 2025
    - 108 bytes
    - Click Count (0)
  10. okhttp-coroutines/src/main/kotlin/okhttp3/coroutines/ExecuteAsync.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     *
     */
    
    package okhttp3.coroutines
    
    import kotlin.coroutines.resumeWithException
    import kotlinx.coroutines.suspendCancellableCoroutine
    import okhttp3.Call
    import okhttp3.Callback
    import okhttp3.Response
    import okhttp3.internal.closeQuietly
    import okio.IOException
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jun 19 04:20:30 GMT 2025
    - 1.4K bytes
    - Click Count (1)
Back to Top