Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 361 - 370 of 516 for streams (0.06 seconds)

  1. impl/maven-core/src/test/java/org/apache/maven/project/EmptyLifecycleBindingsInjector.java

            return Plugin.newBuilder()
                    .groupId("org.apache.maven.plugins")
                    .artifactId(artifactId)
                    .executions(Arrays.stream(goals)
                            .map(goal -> PluginExecution.newBuilder()
                                    .id("default-" + goal)
                                    .goals(List.of(goal))
                                    .build())
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Mar 21 04:56:21 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  2. impl/maven-core/src/main/java/org/apache/maven/internal/transformation/impl/TransformedArtifact.java

     * KIND, either express or implied.  See the License for the
     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.internal.transformation.impl;
    
    import javax.xml.stream.XMLStreamException;
    
    import java.io.File;
    import java.io.IOException;
    import java.nio.file.Files;
    import java.nio.file.Path;
    import java.util.List;
    import java.util.Objects;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Nov 06 18:32:25 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/collect/ImmutableEnumMap.java

      @Override
      @J2ktIncompatible // serialization
      Object writeReplace() {
        return new EnumSerializedForm<>(delegate);
      }
    
      @J2ktIncompatible // serialization
      private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use EnumSerializedForm");
      }
    
      /*
       * This class is used to serialize ImmutableEnumMap instances.
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/collect/EmptyContiguousSet.java

      @J2ktIncompatible
        @Override
      Object writeReplace() {
        return new SerializedForm<>(domain);
      }
    
      @GwtIncompatible
      @J2ktIncompatible
        private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      @GwtIncompatible // NavigableSet
      @Override
      ImmutableSortedSet<C> createDescendingSet() {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  5. 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Sep 23 19:35:41 GMT 2024
    - 2.5K bytes
    - Click Count (0)
  6. compat/maven-embedder/src/main/java/org/apache/maven/cli/props/MavenPropertiesLoader.java

                            tokStarted = true;
                            tokBuf.append(tok.trim());
                            break;
                    }
                }
    
                // Handle case where end of token stream and
                // still got data
                if ((!exit) && (tokStarted)) {
                    retVal = tokBuf.toString();
                }
            }
    
            return optional ? "?" + retVal : retVal;
        }
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jan 24 17:29:44 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  7. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/LayeredOptions.java

            return collectMapIfPresentOrEmpty(Options::userProperties);
        }
    
        @Override
        public String source() {
            return String.format(
                    "layered(%s)", options.stream().map(Options::source).toList());
        }
    
        @Override
        public Optional<Boolean> showVersionAndExit() {
            return returnFirstPresentOrEmpty(Options::showVersionAndExit);
        }
    
        @Override
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Feb 26 17:31:44 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  8. impl/maven-core/src/test/java/org/apache/maven/project/PluginConnectionSimpleTest.java

            // Also verify the change is reflected in the build plugins list
            Plugin pluginFromBuildList = project.getBuild().getPlugins().stream()
                    .filter(p -> "org.apache.maven.plugins:maven-compiler-plugin".equals(p.getKey()))
                    .findFirst()
                    .orElse(null);
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jul 04 12:50:13 GMT 2025
    - 5K bytes
    - Click Count (0)
  9. internal/config/compress/compress.go

    	EnvCompressMimeTypes       = "MINIO_COMPRESSION_MIME_TYPES"
    
    	// Include-list for compression.
    	DefaultExtensions = ".txt,.log,.csv,.json,.tar,.xml,.bin"
    	DefaultMimeTypes  = "text/*,application/json,application/xml,binary/octet-stream"
    )
    
    // DefaultKVS - default KV config for compression settings
    var (
    	DefaultKVS = config.KVS{
    		config.KV{
    			Key:   config.Enable,
    			Value: config.EnableOff,
    		},
    		config.KV{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Sep 06 17:37:10 GMT 2025
    - 5K bytes
    - Click Count (0)
  10. internal/s3select/genmessage.go

    	buf.WriteByte(7)
    	buf.Write([]byte{0, 5})
    	buf.WriteString("event")
    
    	buf.WriteByte(13)
    	buf.WriteString(":content-type")
    	buf.WriteByte(7)
    	buf.Write([]byte{0, 24})
    	buf.WriteString("application/octet-stream")
    
    	buf.WriteByte(11)
    	buf.WriteString(":event-type")
    	buf.WriteByte(7)
    	buf.Write([]byte{0, 7})
    	buf.WriteString("Records")
    
    	fmt.Println(buf.Bytes())
    }
    
    // Continuation Message
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 19 01:35:22 GMT 2021
    - 4.4K bytes
    - Click Count (0)
Back to Top