Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 58 for stop (0.16 sec)

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

    `Stop` methods have not been called.
    Earlier versions of Go did not collect unstopped `Timer`s until after
    they had fired and never collected unstopped `Ticker`s.
    
    Second, the timer channel associated with a `Timer` or `Ticker` is
    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
    Plain Text
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Fri Apr 12 20:57:18 GMT 2024
    - 1.5K bytes
    - Viewed (0)
  2. analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirSymbolDeclarationOverridesProvider.kt

            }
            is FirProperty -> processOverriddenProperties(declaration.symbol) { symbol ->
                processor.invoke(symbol.fir)
                ProcessorAction.NEXT
            }
            else -> ProcessorAction.STOP
        }
    
        private fun FirTypeScope.processDirectOverriddenDeclarations(
            declaration: FirDeclaration,
            processor: (FirCallableDeclaration) -> Unit
        ) = when (declaration) {
    Plain Text
    - Registered: Fri Apr 26 08:18:10 GMT 2024
    - Last Modified: Fri Mar 22 14:22:10 GMT 2024
    - 9.6K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

                minDelayNanos = minOf(candidateDelay, minDelayNanos)
                continue@eachQueue
              }
    
              // If we already have more than one task, that's enough work for now. Stop searching.
              readyTask != null -> {
                multipleReadyTasks = true
                break@eachQueue
              }
    
              // We have a task to execute when we complete the loop.
              else -> {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt

            flags = if (ack) FLAG_ACK else FLAG_NONE,
          )
          sink.writeInt(payload1)
          sink.writeInt(payload2)
          sink.flush()
        }
      }
    
      /**
       * Tell the peer to stop creating streams and that we last processed `lastGoodStreamId`, or zero
       * if no streams were processed.
       *
       * @param lastGoodStreamId the last stream ID processed, or zero if no streams were processed.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  5. doc/godebug.md

    and the [go command documentation](/cmd/go#hdr-Build_and_test_caching).
    
    ### Go 1.23
    
    Go 1.23 changed the channels created by package time to be unbuffered
    (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop)
    and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier.
    The [`asynctimerchan` setting](/pkg/time/#NewTimer) disables this change.
    There are no runtime metrics for this change,
    Plain Text
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Tue Apr 16 17:29:58 GMT 2024
    - 13.5K bytes
    - Viewed (0)
  6. common-protos/k8s.io/api/batch/v1beta1/generated.proto

      // If the time zone name becomes invalid during the lifetime of a CronJob or due to a change in host
      // configuration, the controller will stop creating new new Jobs and will create a system event with the
      // reason UnknownTimeZone.
      // More information can be found in https://kubernetes.io/docs/concepts/workloads/controllers/cron-jobs/#time-zones
      // +optional
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 5.7K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

        e: IOException?,
      ) {
        var noNewExchangesEvent = false
        lock.withLock {
          if (e is StreamResetException) {
            when {
              e.errorCode == ErrorCode.REFUSED_STREAM -> {
                // Stop using this connection on the 2nd REFUSED_STREAM error.
                refusedStreamCount++
                if (refusedStreamCount > 1) {
                  noNewExchangesEvent = !noNewExchanges
                  noNewExchanges = true
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

      /**
       * Degrades this connection such that new streams can neither be created locally, nor accepted
       * from the remote peer. Existing streams are not impacted. This is intended to permit an endpoint
       * to gracefully stop accepting new requests without harming previously established streams.
       */
      @Throws(IOException::class)
      fun shutdown(statusCode: ErrorCode) {
        writer.withLock {
          val lastGoodStreamId: Int
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 32.6K bytes
    - Viewed (0)
  9. common-protos/k8s.io/api/batch/v1/generated.proto

      // If the time zone name becomes invalid during the lifetime of a CronJob or due to a change in host
      // configuration, the controller will stop creating new new Jobs and will create a system event with the
      // reason UnknownTimeZone.
      // More information can be found in https://kubernetes.io/docs/concepts/workloads/controllers/cron-jobs/#time-zones
      // +optional
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 21.1K bytes
    - Viewed (0)
  10. analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirCallResolver.kt

                }
                scope.processOverriddenFunctions(equalsSymbolFromScope) {
                    if (it == equalsSymbolInAny) {
                        equalsSymbol = equalsSymbolFromScope
                        ProcessorAction.STOP
                    } else {
                        ProcessorAction.NEXT
                    }
                }
            }
            return equalsSymbol ?: equalsSymbolInAny
        }
    
    Plain Text
    - Registered: Fri Apr 26 08:18:10 GMT 2024
    - Last Modified: Thu Apr 25 18:05:58 GMT 2024
    - 70.8K bytes
    - Viewed (1)
Back to top