Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1181 - 1190 of 1,261 for Stream (0.09 seconds)

  1. impl/maven-cli/src/main/java/org/apache/maven/cling/MavenUpCling.java

            return new MavenUpCling(world).run(args, null, null, null, false);
        }
    
        /**
         * ClassWorld Launcher "embedded" entry point: returning exitCode and accepts Class World and streams.
         */
        public static int main(
                String[] args,
                ClassWorld world,
                @Nullable InputStream stdIn,
                @Nullable OutputStream stdOut,
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 3K bytes
    - Click Count (0)
  2. SECURITY.md

    for the past five days please contact the security team directly:
    
    - Primary security coordinator: ******@****.***
    - Secondary coordinator: ******@****.***
    - If you receive no response: ******@****.***
    
    ### Disclosure Process
    
    MinIO uses the following disclosure process:
    
    1. Once the security report is received one member of the security team tries to verify and reproduce
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat Feb 12 00:51:25 GMT 2022
    - 2.2K bytes
    - Click Count (0)
  3. internal/s3select/jstream/errors.go

    package jstream
    
    import (
    	"fmt"
    	"strconv"
    )
    
    // Predefined errors
    var (
    	ErrSyntax        = DecoderError{msg: "invalid character"}
    	ErrUnexpectedEOF = DecoderError{msg: "unexpected end of JSON input"}
    	ErrMaxDepth      = DecoderError{msg: "maximum recursion depth exceeded"}
    )
    
    type errPos [2]int // line number, byte offset where error occurred
    
    // DecoderError contains a detailed decoding error.
    type DecoderError struct {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Sep 23 19:35:41 GMT 2024
    - 1.3K bytes
    - Click Count (0)
  4. mockwebserver/src/main/kotlin/mockwebserver3/internal/MockWebServerSocket.kt

    import okio.buffer
    
    /**
     * Adapts a [java.net.Socket] to MockWebServer's needs.
     *
     * Note that [asOkioSocket] returns a socket that closes the underlying [java.net.Socket] when both
     * of its component streams are closed. This class takes advantage of that.
     */
    internal class MockWebServerSocket(
      val javaNetSocket: Socket,
    ) : Closeable,
      BufferedSocket {
      private val delegate = javaNetSocket.asOkioSocket()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  5. build-tools-internal/src/main/resources/changelog-schema.json

                "Cluster Coordination",
                "Discovery-Plugins",
                "Distributed",
                "EQL",
                "Engine",
                "FIPS",
                "Features/CAT APIs",
                "Features/Data streams",
                "Features/Features",
                "Features/ILM+SLM",
                "Features/Indices APIs",
                "Features/Ingest",
                "Features/Java High Level REST Client",
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Wed Sep 01 06:25:29 GMT 2021
    - 5K bytes
    - Click Count (0)
  6. impl/maven-cli/src/main/java/org/apache/maven/cling/MavenEncCling.java

            return new MavenEncCling(world).run(args, null, null, null, false);
        }
    
        /**
         * ClassWorld Launcher "embedded" entry point: returning exitCode and accepts Class World and streams.
         */
        public static int main(
                String[] args,
                ClassWorld world,
                @Nullable InputStream stdIn,
                @Nullable OutputStream stdOut,
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 3K bytes
    - Click Count (0)
  7. impl/maven-cli/src/main/java/org/apache/maven/cling/MavenShellCling.java

            return new MavenShellCling(world).run(args, null, null, null, false);
        }
    
        /**
         * ClassWorld Launcher "embedded" entry point: returning exitCode and accepts Class World and streams.
         */
        public static int main(
                String[] args,
                ClassWorld world,
                @Nullable InputStream stdIn,
                @Nullable OutputStream stdOut,
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 3K bytes
    - Click Count (0)
  8. internal/s3select/jstream/scanner.go

    package jstream
    
    import (
    	"io"
    	"sync/atomic"
    )
    
    const (
    	chunk    = 4095 // ~4k
    	maxUint  = ^uint(0)
    	maxInt   = int64(maxUint >> 1)
    	nullByte = byte(0)
    )
    
    type scanner struct {
    	pos       int64 // position in reader
    	ipos      int64 // internal buffer position
    	ifill     int64 // internal buffer fill
    	end       int64
    	buf       [chunk + 1]byte // internal buffer (with a lookback size of 1)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Sep 23 19:35:41 GMT 2024
    - 2.5K bytes
    - Click Count (0)
  9. impl/maven-cli/src/main/java/org/apache/maven/cling/MavenCling.java

            return new MavenCling(world).run(args, null, null, null, false);
        }
    
        /**
         * ClassWorld Launcher "embedded" entry point: returning exitCode and accepts Class World and streams.
         */
        public static int main(
                String[] args,
                ClassWorld world,
                @Nullable InputStream stdIn,
                @Nullable OutputStream stdOut,
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 3K bytes
    - Click Count (0)
  10. .github/workflows/notify-on-rc-for-manual-test.yml

    name: IDE Experience team notifier
    run-name: Notify the IDE Experience team about new RCs for manual testing
    on:
      push:
        tags:
          - 'v*.*.*-RC1'
    
    permissions: {}
    
    jobs:
      send-slack-notification:
        runs-on: ubuntu-latest
        steps:
          - name: Send Slack notification about new RCs for manual testing
            id: slack
            uses: slackapi/slack-github-action@v3.0.1
            with:
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Fri Mar 13 22:04:33 GMT 2026
    - 912 bytes
    - Click Count (0)
Back to Top