Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 478 for source (0.23 sec)

  1. okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt

        val source2 = relay.newSource()!!.buffer()
        assertThat(source1.readUtf8(5)).isEqualTo("abcde")
        assertThat(source2.readUtf8(5)).isEqualTo("abcde")
        assertThat(source2.readUtf8(5)).isEqualTo("fghij")
        assertThat(source1.readUtf8(5)).isEqualTo("fghij")
        assertThat(source1.exhausted()).isTrue()
        assertThat(source2.exhausted()).isTrue()
        source1.close()
        source2.close()
        assertThat(relay.isClosed).isTrue()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 8.1K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/MultipartReader.kt

        private var closed = false
        private var noMoreParts = false
    
        /** This is only part that's allowed to read from the underlying source. */
        private var currentPart: PartSource? = null
    
        @Throws(IOException::class)
        constructor(response: ResponseBody) : this(
          source = response.source(),
          boundary =
            response.contentType()?.parameter("boundary")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  3. analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/symbols/descriptorBased/base/KtFe10DescSymbol.kt

            }
    
        override val psi: PsiElement?
            get() = withValidityAssertion {
                (source as? PsiSourceElement)?.psi
                    ?: KtFe10ReferenceResolutionHelper.getInstance()
                        ?.findDecompiledDeclaration(analysisContext.resolveSession.project, descriptor, null)
            }
    
        override val origin: KtSymbolOrigin
    Plain Text
    - Registered: Fri Apr 26 08:18:10 GMT 2024
    - Last Modified: Wed Jun 07 21:46:49 GMT 2023
    - 1.8K bytes
    - Viewed (0)
  4. docker/Dockerfile.distroless

    # prepare a distroless source context to copy files from
    FROM gcr.io/distroless/static-debian11@sha256:9be3fcc6abeaf985b5ecce59451acbcbb15e7be39472320c538d0d55a0834edc as distroless_source
    
    # prepare a base dev to modify file contents
    FROM ubuntu:noble as ubuntu_source
    
    # Modify contents of container
    COPY --from=distroless_source /etc/ /home/etc
    COPY --from=distroless_source /home/nonroot /home/nonroot
    RUN echo istio-proxy:x:1337: >> /home/etc/group
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 18:50:51 GMT 2024
    - 836 bytes
    - Viewed (0)
  5. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt

          .build()
      private val STORY_JSON_ADAPTER = MOSHI.adapter(Story::class.java)
    
      private val fileSystem = FileSystem.SYSTEM
    
      private fun readStory(source: BufferedSource): Story {
        return STORY_JSON_ADAPTER.fromJson(source)!!
      }
    
      private fun readStory(file: Path): Story {
        fileSystem.read(file) {
          return readStory(this)
        }
      }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3.3K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/io/FaultyFileSystem.kt

        } else {
          renameFaults.remove(file)
        }
      }
    
      @Throws(IOException::class)
      override fun atomicMove(
        source: Path,
        target: Path,
      ) {
        if (renameFaults.contains(source) || renameFaults.contains(target)) throw IOException("boom!")
        super.atomicMove(source, target)
      }
    
      @Throws(IOException::class)
      override fun delete(
        path: Path,
        mustExist: Boolean,
      ) {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  7. okhttp-testing-support/src/main/kotlin/okhttp3/okio/LoggingFilesystem.kt

      override fun sink(
        path: Path,
        mustCreate: Boolean,
      ): Sink {
        log("sink($path)")
    
        return super.sink(path, mustCreate)
      }
    
      override fun source(file: Path): Source {
        log("source($file)")
    
        return super.source(file)
      }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.7K bytes
    - Viewed (0)
  8. build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/sources/SourcesRepository.kt

            openKotlinCompilationUnitsByRoot.clear()
            if (errors.isNotEmpty()) {
                throw Exception("Sources repository did not close cleanly").apply {
                    errors.forEach(this::addSuppressed)
                }
            }
        }
    
        /**
         * @return the source file and it's source root
         */
        fun sourceFileAndSourceRootFor(sourceFilePath: String): Pair<File, File> =
    Plain Text
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Mon Feb 20 16:37:41 GMT 2023
    - 4K bytes
    - Viewed (0)
  9. apache-maven/src/main/appended-resources/META-INF/NOTICE.vm

    indicated below, the terms and conditions of the EPL still apply to any source code in the Content
    and such source code may be obtained at <a href="http://www.eclipse.org/">http://www.eclipse.org</a>.</p>
    
    <h3>Third Party Content</h3>
    <p>The Content includes items that have been sourced from third parties as set
    out below. If you did not receive this Content directly from the Eclipse Foundation,
    Plain Text
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Sat Sep 10 19:27:25 GMT 2022
    - 5.5K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/SocksProxy.kt

            // Copy sources to sinks in both directions.
            val toSource = toSocket.source().buffer()
            val toSink = toSocket.sink().buffer()
            openSockets.add(toSocket)
            transfer(fromAddress, toAddress, fromSource, toSink)
            transfer(fromAddress, toAddress, toSource, fromSink)
          }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 7.7K bytes
    - Viewed (0)
Back to top