Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 493 for streams (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/event/target/nats.go

    		return err
    	}
    
    	if target.natsConn != nil && args.JetStream.Enable {
    		var jstream nats.JetStream
    		jstream, err = target.natsConn.JetStream()
    		if err != nil {
    			if err.Error() != nats.ErrNoServers.Error() {
    				target.loggerOnce(context.Background(), err, target.ID().String())
    			}
    			return err
    		}
    		target.jstream = jstream
    	}
    
    	yes, err := target.isActive()
    	if err != nil {
    		return err
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/AbstractBiMap.java

            private void writeObject(ObjectOutputStream stream) throws IOException {
          stream.defaultWriteObject();
          stream.writeObject(inverse());
        }
    
        @GwtIncompatible
        @J2ktIncompatible
            @SuppressWarnings("unchecked") // reading data stored by writeObject
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
          stream.defaultReadObject();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 15:50:50 GMT 2025
    - 14.3K bytes
    - Click Count (0)
  3. compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/scopes/Maven3ScopeManagerConfiguration.java

     * under the License.
     */
    package org.apache.maven.repository.internal.scopes;
    
    import java.util.ArrayList;
    import java.util.Arrays;
    import java.util.Collection;
    import java.util.Collections;
    import java.util.stream.Collectors;
    
    import org.eclipse.aether.artifact.ArtifactProperties;
    import org.eclipse.aether.impl.scope.BuildScopeMatrixSource;
    import org.eclipse.aether.impl.scope.BuildScopeSource;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 7.7K bytes
    - Click Count (0)
  4. impl/maven-core/src/main/java/org/apache/maven/graph/DefaultGraphBuilder.java

                File reactorDirectory = projectSelector.getBaseDirectoryFromRequest(request);
    
                String selector = request.getResumeFrom();
    
                MavenProject resumingFromProject = projects.stream()
                        .filter(project -> projectSelector.isMatchingProject(project, selector, reactorDirectory))
                        .findFirst()
                        .orElseThrow(() -> new MavenExecutionException(
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Feb 11 16:38:19 GMT 2025
    - 18.5K bytes
    - Click Count (0)
  5. impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultTypeRegistry.java

        public Type require(String id) {
            requireNonNull(id, "id cannot be null");
            return usedTypes.computeIfAbsent(id, i -> {
                Type type = lookup.lookupList(TypeProvider.class).stream()
                        .flatMap(p -> p.provides().stream())
                        .filter(t -> Objects.equals(id, t.id()))
                        .findFirst()
                        .orElse(null);
                if (type == null) {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed May 14 04:47:58 GMT 2025
    - 4K bytes
    - Click Count (0)
  6. compat/maven-model/src/test/java/org/apache/maven/model/v4/Xpp3DomPerfTest.java

     * under the License.
     */
    package org.apache.maven.model.v4;
    
    import javax.xml.stream.XMLStreamException;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.nio.file.Files;
    import java.nio.file.Path;
    import java.nio.file.Paths;
    import java.util.List;
    import java.util.concurrent.TimeUnit;
    import java.util.stream.Collectors;
    
    import org.apache.maven.api.model.InputSource;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Mon Sep 29 14:45:25 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  7. guava/src/com/google/common/collect/CompactHashMap.java

      @J2ktIncompatible
      private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        stream.writeInt(size());
        Iterator<Entry<K, V>> entryIterator = entrySetIterator();
        while (entryIterator.hasNext()) {
          Entry<K, V> e = entryIterator.next();
          stream.writeObject(e.getKey());
          stream.writeObject(e.getValue());
        }
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 39.6K bytes
    - Click Count (0)
  8. compat/maven-model/src/main/java/org/apache/maven/model/InputLocation.java

     * KIND, either express or implied.  See the License for the
     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.model;
    
    import java.util.stream.Collectors;
    
    /**
     * Class InputLocation.
     *
     * @version $Revision$ $Date$
     */
    @SuppressWarnings("all")
    public final class InputLocation implements java.io.Serializable, Cloneable, InputLocationTracker {
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Mon Sep 29 14:45:25 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  9. compat/maven-model-builder/src/main/java/org/apache/maven/utils/Os.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.utils;
    
    import java.io.File;
    import java.util.Locale;
    import java.util.stream.Stream;
    
    /**
     * OS support
     *
     * @deprecated use {@code org.apache.maven.api.services.ModelBuilder} instead
     */
    @Deprecated(since = "4.0.0")
    public class Os {
    
        /**
         * The OS Name.
         */
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Oct 16 06:12:36 GMT 2025
    - 7.2K bytes
    - Click Count (0)
  10. impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/goals/ModelUpgradeStrategyTest.java

     */
    package org.apache.maven.cling.invoker.mvnup.goals;
    
    import java.nio.file.Path;
    import java.nio.file.Paths;
    import java.util.HashMap;
    import java.util.Map;
    import java.util.Optional;
    import java.util.stream.Stream;
    
    import eu.maveniverse.domtrip.Document;
    import eu.maveniverse.domtrip.Editor;
    import eu.maveniverse.domtrip.Element;
    import org.apache.maven.api.cli.mvnup.UpgradeOptions;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Nov 18 18:03:26 GMT 2025
    - 38.8K bytes
    - Click Count (0)
Back to Top