Search Options

Results per page
Sort
Preferred Languages
Advance

Results 631 - 640 of 1,014 for jstream (0.06 sec)

  1. impl/maven-core/src/main/java/org/apache/maven/internal/transformation/impl/ConsumerPomArtifactTransformer.java

     * under the License.
     */
    package org.apache.maven.internal.transformation.impl;
    
    import javax.inject.Inject;
    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.nio.file.Files;
    import java.nio.file.Path;
    import java.nio.file.Paths;
    import java.util.ArrayList;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Thu Nov 06 18:32:25 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  2. internal/grid/manager.go

    	// Copy so clients can also pick it up for other subpaths.
    	m.handlers.subSingle[makeZeroSubHandlerID(id)] = h
    	return nil
    }
    
    /*
    // RegisterStateless will register a stateless handler that serves
    // []byte -> stream of ([]byte, error) requests.
    func (m *Manager) RegisterStateless(id HandlerID, h StatelessHandler) error {
    	if !id.valid() {
    		return ErrUnknownHandler
    	}
    	if m.handlers.hasAny(id) && !id.isTestHandler() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Nov 12 20:41:41 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  3. src/test/java/jcifs/internal/smb2/nego/NegotiateContextResponseTest.java

    import static org.junit.jupiter.api.Assertions.assertNotNull;
    import static org.junit.jupiter.api.Assertions.assertNull;
    import static org.junit.jupiter.api.Assertions.assertTrue;
    
    import java.util.Arrays;
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Nested;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.extension.ExtendWith;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 19.4K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

    import java.util.ArrayList;
    import java.util.List;
    import java.util.Map;
    import java.util.Queue;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.fess.crawler.Constants;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:40:57 UTC 2025
    - 16.9K bytes
    - Viewed (1)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

              null
            }
          }
        }
    
        /**
         * Returns a new unbuffered output stream to write the value at [index]. If the underlying
         * output stream encounters errors when writing to the filesystem, this edit will be aborted
         * when [commit] is called. The returned output stream does not throw IOExceptions.
         */
        fun newSink(index: Int): Sink {
          synchronized(this@DiskLruCache) {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/ImmutableAsList.java

        }
    
        @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0;
      }
    
      @GwtIncompatible
      @J2ktIncompatible
        private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      @GwtIncompatible
      @J2ktIncompatible
        @Override
      Object writeReplace() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 2.5K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

      }
    
      /**
       * Returns a new source that writes bytes to [cacheRequest] as they are read by the source
       * consumer. This is careful to discard bytes left over when the stream is closed; otherwise we
       * may never exhaust the source stream and therefore not complete the cached response.
       */
      @Throws(IOException::class)
      private fun cacheWritingResponse(
        cacheRequest: CacheRequest?,
        response: Response,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/base/Optional.java

       * <p><b>Comparison to {@code java.util.Optional}:</b> this method has no equivalent in Java 8's
       * {@code Optional} class; use {@code
       * optionals.stream().filter(Optional::isPresent).map(Optional::get)} instead.
       *
       * <p><b>Java 9 users:</b> use {@code optionals.stream().flatMap(Optional::stream)} instead.
       *
       * @since 11.0 (generics widened in 13.0)
       */
      public static <T> Iterable<T> presentInstances(
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Jun 04 13:03:16 UTC 2025
    - 15.4K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.logging.Level;
    import java.util.logging.Logger;
    import java.util.regex.MatchResult;
    import java.util.regex.Matcher;
    import java.util.regex.Pattern;
    import java.util.stream.Stream;
    import org.jspecify.annotations.NullMarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Supplies an arbitrary "default" instance for a wide range of types, often useful in testing
     * utilities.
     *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 17:50:58 UTC 2025
    - 21.4K bytes
    - Viewed (0)
  10. impl/maven-core/src/test/java/org/apache/maven/configuration/DefaultBeanConfiguratorPathTest.java

     * KIND, either express or implied.  See the License for the
     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.configuration;
    
    import javax.xml.stream.XMLStreamException;
    
    import java.io.File;
    import java.io.StringReader;
    import java.nio.file.Path;
    import java.nio.file.Paths;
    
    import org.apache.maven.api.xml.XmlService;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Mar 25 09:45:07 UTC 2025
    - 3.7K bytes
    - Viewed (0)
Back to top