Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 207 for channel (0.19 sec)

  1. doc/next/6-stdlib/1-time.md

    now unbuffered, with capacity 0.
    The main effect of this change is that Go now guarantees
    that for any call to a `Reset` or `Stop` method, no stale values
    prepared before that call will be sent or received after the call.
    Earlier versions of Go used channels with a one-element buffer,
    making it difficult to use `Reset` and `Stop` correctly.
    A visible effect of this change is that `len` and `cap` of timer channels
    Plain Text
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Apr 12 20:57:18 GMT 2024
    - 1.5K bytes
    - Viewed (0)
  2. .teamcity/src/test/kotlin/PerformanceTestBuildTypeTest.kt

            assertEquals(
                (
                    listOf(
                        "clean",
                        ":performance:largeTestProjectPerformanceTest --channel %performance.channel% ",
                        ":performance:smallTestProjectPerformanceTest --channel %performance.channel% ",
                        "extraParameters"
                    ) + expectedRunnerParams
                    ).joinToString(" "),
    Plain Text
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Wed Apr 24 08:17:56 GMT 2024
    - 7.3K bytes
    - Viewed (0)
  3. src/builtin/builtin.go

    //	specified number of elements. The size may be omitted, in which case
    //	a small starting size is allocated.
    //	Channel: The channel's buffer is initialized with the specified
    //	buffer capacity. If zero, or the size is omitted, the channel is
    //	unbuffered.
    func make(t Type, size ...IntegerType) Type
    
    // The max built-in function returns the largest value of a fixed number of
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Apr 11 20:22:45 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  4. .teamcity/src/main/kotlin/configurations/PerformanceTestsPass.kt

                )
                param("env.PERFORMANCE_DB_PASSWORD_TCAGENT", "%performance.db.password.tcagent%")
                param("performance.db.username", "tcagent")
                param("performance.channel", performanceTestSpec.channel())
            }
    
            features {
                publishBuildStatusToGithub(model)
            }
    
            val performanceResultsDir = "perf-results"
            val performanceProjectName = "performance"
    
    Plain Text
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Thu Apr 04 07:21:42 GMT 2024
    - 5.1K bytes
    - Viewed (0)
  5. manifests/charts/base/templates/validatingadmissionpolicy.yaml

              )
            )
    ---
    apiVersion: admissionregistration.k8s.io/v1
    kind: ValidatingAdmissionPolicyBinding
    metadata:
      name: "stable-channel-default-policy-binding.istio.io"
    spec:
      policyName: "stable-channel-default-policy.istio.io"
      validationActions: [Deny]
    Others
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Apr 22 22:00:40 GMT 2024
    - 1.6K bytes
    - Viewed (0)
  6. .teamcity/src/main/kotlin/configurations/PerformanceTest.kt

                    allowEmpty = true,
                    description = "The baselines you want to run performance tests against. Empty means default baseline."
                )
                param("performance.channel", performanceTestBuildSpec.channel())
                param("env.PERFORMANCE_DB_PASSWORD_TCAGENT", "%performance.db.password.tcagent%")
                when (os) {
                    Os.WINDOWS -> param("env.PATH", "%env.PATH%;C:/Program Files/7-zip")
    Plain Text
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Wed Apr 24 08:17:56 GMT 2024
    - 5.3K bytes
    - Viewed (0)
  7. cmd/sftp-server.go

    					Extensions: make(map[string]string),
    				}, nil
    			}
    			return nil, errAuthentication
    		},
    	}
    
    	sshConfig.AddHostKey(private)
    
    	handleSFTPSession := func(channel ssh.Channel, sconn *ssh.ServerConn) {
    		server := sftp.NewRequestServer(channel, NewSFTPDriver(sconn.Permissions), sftp.WithRSAllocator())
    		defer server.Close()
    		server.Serve()
    	}
    
    	sftpServer, err := xsftp.NewServer(&xsftp.Options{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  8. doc/go1.17_spec.html

    <p>
    A send statement sends a value on a channel.
    The channel expression must be of <a href="#Channel_types">channel type</a>,
    the channel direction must permit send operations,
    and the type of the value to be sent must be <a href="#Assignability">assignable</a>
    to the channel's element type.
    </p>
    
    <pre class="ebnf">
    SendStmt = Channel "&lt;-" Expression .
    Channel  = Expression .
    </pre>
    
    <p>
    HTML
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Apr 11 20:22:45 GMT 2024
    - 211.6K bytes
    - Viewed (0)
  9. ReadMe.md

     * [Kotlin YouTube Channel](https://www.youtube.com/channel/UCP7uiEZIqci43m22KDl0sNw)
     * [Forum](https://discuss.kotlinlang.org/)
     * [Kotlin Blog](https://blog.jetbrains.com/kotlin/)
     * [Subscribe to Kotlin YouTube channel](https://www.youtube.com/channel/UCP7uiEZIqci43m22KDl0sNw)
     * [Follow Kotlin on Twitter](https://twitter.com/kotlin)
     * [Public Slack channel](https://slack.kotlinlang.org/)
    Plain Text
    - Registered: Fri May 03 08:18:13 GMT 2024
    - Last Modified: Thu Apr 11 14:28:46 GMT 2024
    - 8.7K bytes
    - Viewed (0)
  10. cmd/iam-etcd-store.go

    					if !ok {
    						time.Sleep(1 * time.Second)
    						// Upon an error on watch channel
    						// re-init the watch channel.
    						goto outerLoop
    					}
    					if err := watchResp.Err(); err != nil {
    						iamLogIf(ctx, err)
    						// log and retry.
    						time.Sleep(1 * time.Second)
    						// Upon an error on watch channel
    						// re-init the watch channel.
    						goto outerLoop
    					}
    					for _, event := range watchResp.Events {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.6K bytes
    - Viewed (0)
Back to top