Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 46 for Channel (0.06 seconds)

  1. okhttp/src/jvmTest/kotlin/okhttp3/SocketChannelTest.kt

      }
    
      @Test
      fun testHttp(socketMode: SocketMode = burstValues(Channel, Standard)) {
        testConnection(socketMode)
      }
    
      @Test
      fun testHttps(
        provider: Provider = Provider.JSSE,
        protocol: Protocol = burstValues(HTTP_1_1, HTTP_2),
        tlsVersion: TlsVersion = burstValues(TLS_1_3, TLS_1_2),
        socketMode: SocketMode = burstValues(Channel, Standard),
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Nov 01 12:18:11 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  2. src/builtin/builtin.go

    func clear[T ~[]Type | ~map[Type]Type1](t T)
    
    // The close built-in function closes a channel, which must be either
    // bidirectional or send-only. It should be executed only by the sender,
    // never the receiver, and has the effect of shutting down the channel after
    // the last sent value is received. After the last value has been received
    // from a closed channel c, any receive from c will succeed without
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Feb 26 17:14:40 GMT 2026
    - 13.2K bytes
    - Click Count (0)
  3. .teamcity/src/main/kotlin/model/CIBuildModel.kt

        val defaultBaselines: String = "",
        val channel: String,
        val extraParameters: String = "",
    ) {
        PER_COMMIT(
            displayName = "Performance Regression Test",
            timeout = 420,
            channel = "commits",
        ),
        PER_DAY(
            displayName = "Slow Performance Regression Test",
            timeout = 420,
            channel = "commits",
        ),
        PER_WEEK(
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Jan 20 03:53:25 GMT 2026
    - 27.5K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/io/ByteStreams.java

          to.write(buf, 0, r);
          total += r;
        }
        return total;
      }
    
      /**
       * Copies all bytes from the readable channel to the writable channel. Does not close or flush
       * either channel.
       *
       * @param from the readable channel to read from
       * @param to the writable channel to write to
       * @return the number of bytes copied
       * @throws IOException if an I/O error occurs
       */
      @J2ktIncompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 31.1K bytes
    - Click Count (0)
  5. doc/go_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>
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Wed Apr 01 23:39:18 GMT 2026
    - 287.8K bytes
    - Click Count (1)
  6. cmd/metrics.go

    			nil, nil),
    		prometheus.GaugeValue,
    		float64(nodesDown),
    	)
    }
    
    // collects healing specific metrics for MinIO instance in Prometheus specific format
    // and sends to given channel
    func healingMetricsPrometheus(ch chan<- prometheus.Metric) {
    	bgSeq, exists := globalBackgroundHealState.getHealSequenceByToken(bgHealingUUID)
    	if !exists {
    		return
    	}
    
    	var dur time.Duration
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:06:31 GMT 2025
    - 16.7K bytes
    - Click Count (0)
  7. internal/stmt_store/stmt_store.go

    	// The prepared channel is used to synchronize the statement preparation state.
    	cacheStmt := &Stmt{
    		Transaction: isTransaction,
    		prepared:    make(chan struct{}),
    	}
    	// Cache the Stmt object with the associated key.
    	s.Set(key, cacheStmt)
    	// Unlock after completing initialization to prevent deadlocks.
    	locker.Unlock()
    
    	// Ensure the prepared channel is closed after the function execution completes.
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 6.1K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/core/io/FileUtil.java

            assertArgumentNotNull("file", file);
    
            final FileInputStream is = InputStreamUtil.create(file);
            try {
                final FileChannel channel = is.getChannel();
                final long fileSize = ChannelUtil.size(channel);
    
                if (fileSize > maxSize) {
                    throw new IORuntimeException(new IOException(
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Thu Feb 12 12:10:45 GMT 2026
    - 13.2K bytes
    - Click Count (0)
  9. README.md

    - **Community Forum**: Engage with others on the [Gradle Forum](https://discuss.gradle.org/) for discussions, tips, and best practices.
    - **Community Slack**: [Join our Slack Channel](https://gradle.org/slack-invite) for real-time discussions, with specialized channels like `#github-integrations` for integration topics.
    - **Newsletter**: Subscribe to the [Gradle Newsletter](https://newsletter.gradle.org) for news, tutorials, and community highlights.
    
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Feb 12 18:58:41 GMT 2026
    - 7.8K bytes
    - Click Count (0)
  10. README.md

    *   [Learn ML with TensorFlow](https://www.tensorflow.org/resources/learn-ml)
    *   [TensorFlow Twitter](https://twitter.com/tensorflow)
    *   [TensorFlow YouTube](https://www.youtube.com/channel/UC0rqucBdTuFTjJiefW5t-IQ)
    *   [TensorFlow model optimization roadmap](https://www.tensorflow.org/model_optimization/guide/roadmap)
    *   [TensorFlow White Papers](https://www.tensorflow.org/about/bib)
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Thu Apr 02 10:38:57 GMT 2026
    - 11.6K bytes
    - Click Count (0)
Back to Top