Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 84 for delegate (0.24 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt

        c = c.superclass
      }
    
      // Didn't find the field we wanted. As a last gasp attempt,
      // try to find the value on a delegate.
      if (fieldName != "delegate") {
        val delegate = readFieldOrNull(instance, Any::class.java, "delegate")
        if (delegate != null) return readFieldOrNull(delegate, fieldType, fieldName)
      }
    
      return null
    }
    
    @JvmField
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 09 12:33:05 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

       * like [poll]. It is only usable within task faker tasks.
       */
      private inner class TaskFakerBlockingQueue<T>(
        val delegate: BlockingQueue<T>,
      ) : AbstractQueue<T>(), BlockingQueue<T> {
        override val size: Int = delegate.size
    
        private var editCount = 0
    
        override fun poll(): T = delegate.poll()
    
        override fun poll(
          timeout: Long,
          unit: TimeUnit,
        ): T? {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 12.6K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/ResponseBody.kt

      ) : Reader() {
        private var closed: Boolean = false
        private var delegate: Reader? = null
    
        @Throws(IOException::class)
        override fun read(
          cbuf: CharArray,
          off: Int,
          len: Int,
        ): Int {
          if (closed) throw IOException("Stream closed")
    
          val finalDelegate =
            delegate ?: InputStreamReader(
              source.inputStream(),
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.7K bytes
    - Viewed (0)
  4. analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirCompilerFacility.kt

            }
        }
    
        private class CompilerFacilityJvmGeneratorExtensions(
            private val delegate: JvmGeneratorExtensions
        ) : StubGeneratorExtensions(), JvmGeneratorExtensions by delegate {
            override fun generateRawTypeAnnotationCall(): IrConstructorCall? = delegate.generateRawTypeAnnotationCall()
    
            /**
    Plain Text
    - Registered: Fri Apr 26 08:18:10 GMT 2024
    - Last Modified: Fri Apr 19 11:06:47 GMT 2024
    - 32.2K bytes
    - Viewed (1)
  5. okhttp/src/main/kotlin/okhttp3/Cache.kt

          private val delegate: MutableIterator<DiskLruCache.Snapshot> = cache.snapshots()
          private var nextUrl: String? = null
          private var canRemove = false
    
          override fun hasNext(): Boolean {
            if (nextUrl != null) return true
    
            canRemove = false // Prevent delegate.remove() on the wrong item!
            while (delegate.hasNext()) {
              try {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 26.8K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/DuplexTest.kt

      }
    
      private inner class DelayedRequestBody(
        private val delegate: RequestBody,
        delay: Long,
        timeUnit: TimeUnit,
      ) : RequestBody() {
        private val delayMillis = timeUnit.toMillis(delay)
    
        override fun contentType() = delegate.contentType()
    
        override fun isDuplex() = true
    
        override fun writeTo(sink: BufferedSink) {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 23.9K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

        return UnknownLengthSource()
      }
    
      /**
       * Sets the delegate of `timeout` to [Timeout.NONE] and resets its underlying timeout
       * to the default configuration. Use this to avoid unexpected sharing of timeouts between pooled
       * connections.
       */
      private fun detachTimeout(timeout: ForwardingTimeout) {
        val oldDelegate = timeout.delegate
        timeout.setDelegate(Timeout.NONE)
        oldDelegate.clearDeadline()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 16.2K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

            synchronized(this@DiskLruCache) {
              // If the cache is closed, truncate the iterator.
              if (closed) return false
    
              while (delegate.hasNext()) {
                nextSnapshot = delegate.next()?.snapshot() ?: continue
                return true
              }
            }
    
            return false
          }
    
          override fun next(): Snapshot {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 34.7K bytes
    - Viewed (0)
  9. analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/components/KtFe10CallResolver.kt

            )
    
            val diagnosticWithResolvedCallsAtPosition2 = setOf(
                Errors.COMPONENT_FUNCTION_AMBIGUITY,
                Errors.DELEGATE_SPECIAL_FUNCTION_AMBIGUITY,
                Errors.DELEGATE_SPECIAL_FUNCTION_NONE_APPLICABLE,
                Errors.DELEGATE_PD_METHOD_NONE_APPLICABLE,
            )
    
            private val DiagnosticFactoryForDeprecation<*, *, *>.factories: Array<DiagnosticFactoryWithPsiElement<*, *>>
    Plain Text
    - Registered: Fri May 03 08:18:13 GMT 2024
    - Last Modified: Mon Apr 29 12:48:54 GMT 2024
    - 34.8K bytes
    - Viewed (0)
  10. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt

      private class CountingSource(source: Source) : ForwardingSource(source) {
        var bytesRead = 0L
    
        override fun read(
          sink: Buffer,
          byteCount: Long,
        ): Long {
          val result = delegate.read(sink, byteCount)
          if (result == -1L) return -1L
          bytesRead += result
          return result
        }
      }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.5K bytes
    - Viewed (0)
Back to top