- Sort Score
- Num 10 results
- Language All
Results 341 - 350 of 516 for streams (0.04 seconds)
-
internal/bucket/lifecycle/tag.go
) // UnmarshalXML - decodes XML data. func (tag *Tag) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) { var keyAlreadyParsed, valueAlreadyParsed bool for { // Read tokens from the XML document in a stream. t, err := d.Token() if err != nil { if err == io.EOF { break } return err } if se, ok := t.(xml.StartElement); ok { var s string
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 2.4K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/transformation/impl/TransformerSupport.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.IOException; import java.io.InputStream; import java.io.Writer; import java.nio.file.Files; import java.nio.file.Path; import org.apache.maven.api.model.Model;
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Thu Nov 06 18:32:25 GMT 2025 - 3.4K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/plugin/internal/DeprecatedPluginValidator.java
mojoClass, logDeprecatedMojo(mojoDescriptor)); } if (mojoDescriptor.getParameters() != null) { mojoDescriptor.getParameters().stream() .filter(parameter -> parameter.getDeprecated() != null) .filter(Parameter::isEditable) .forEach(parameter -> checkParameter(Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 4.1K bytes - Click Count (0) -
internal/s3select/jstream/scratch.go
package jstream import ( "unicode/utf8" ) type scratch struct { data []byte fill int } // reset scratch buffer func (s *scratch) reset() { s.fill = 0 } // bytes returns the written contents of scratch buffer func (s *scratch) bytes() []byte { return s.data[0:s.fill] } // grow scratch buffer func (s *scratch) grow() { ndata := make([]byte, cap(s.data)*2) copy(ndata, s.data) s.data = ndata }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Sep 23 19:35:41 GMT 2024 - 758 bytes - Click Count (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/BasicJavadocLexer.java
package gradlebuild.docs.dsl.docbook; import java.util.HashMap; import java.util.Locale; import java.util.Map; import java.util.regex.Pattern; /** * Converts the main description of a javadoc comment into a stream of tokens. */ class BasicJavadocLexer implements JavadocLexer { private static final Pattern HTML_ELEMENT = Pattern.compile("(?s)<\\\\?[^<]+?>");Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Mon Aug 19 15:07:24 GMT 2024 - 7.1K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/extensions/BootstrapCoreExtensionManager.java
import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.NoSuchElementException; import java.util.Set; import java.util.function.UnaryOperator; import java.util.stream.Collectors; import org.apache.maven.RepositoryUtils; import org.apache.maven.api.Service; import org.apache.maven.api.Session; import org.apache.maven.api.annotations.Nullable;
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Dec 16 13:41:14 GMT 2025 - 13.9K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/AtomicDoubleArray.java
b.append(longBitsToDouble(longs.get(i))); if (i == iMax) { return b.append(']').toString(); } b.append(',').append(' '); } } /** * Saves the state to a stream (that is, serializes it). * * @serialData The length of the array is emitted (int), followed by all of its elements (each a * {@code double}) in the proper order. */
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 10.2K bytes - Click Count (0) -
guava-testlib/test/com/google/common/testing/ClassSanityTesterTest.java
import java.util.AbstractList; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; import java.util.stream.Stream; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /** * Unit tests for {@link ClassSanityTester}. *Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 16:03:47 GMT 2025 - 36.3K bytes - Click Count (0) -
compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/DefaultSettingsReader.java
* specific language governing permissions and limitations * under the License. */ package org.apache.maven.settings.io; import javax.inject.Named; import javax.inject.Singleton; import javax.xml.stream.XMLStreamException; import java.io.File; import java.io.IOException; import java.io.InputStream; import java.io.Reader; import java.nio.file.Files; import java.util.Map; import java.util.Objects;
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Mon Sep 29 14:45:25 GMT 2025 - 3.6K bytes - Click Count (0) -
impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/cisupport/CIDetectorHelperTest.java
ProcessBuilder processBuilder = new ProcessBuilder(path, "-cp", classpath, CIDetectorHelperRunner.class.getName()); processBuilder.environment().putAll(add); ALL.stream() .filter(s -> !add.containsKey(s)) .forEach(k -> processBuilder.environment().remove(k)); Process process = processBuilder.start(); process.waitFor();Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sun Apr 13 18:50:07 GMT 2025 - 3.4K bytes - Click Count (0)