Search Options

Results per page
Sort
Preferred Languages
Advance

Results 681 - 690 of 739 for CStream (0.08 sec)

  1. guava-tests/test/com/google/common/collect/ImmutableMultisetTest.java

    import java.util.Arrays;
    import java.util.Collection;
    import java.util.HashSet;
    import java.util.Iterator;
    import java.util.List;
    import java.util.Set;
    import java.util.function.BiPredicate;
    import java.util.stream.Collector;
    import junit.framework.Test;
    import junit.framework.TestCase;
    import junit.framework.TestSuite;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Tests for {@link ImmutableMultiset}.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/ImmutableCollection.java

        // We serialize by default to ImmutableList, the simplest thing that works.
        return new ImmutableList.SerializedForm(toArray());
      }
    
      @J2ktIncompatible // serialization
      private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      /**
       * Abstract base class for builders of {@link ImmutableCollection} types.
       *
       * @since 10.0
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Aug 12 16:59:15 UTC 2024
    - 18.8K bytes
    - Viewed (0)
  3. internal/logger/target/http/http.go

    	migrateTarget *Target
    
    	// Number of events per HTTP send to webhook target
    	// this is ideally useful only if your endpoint can
    	// support reading multiple events on a stream for example
    	// like : Splunk HTTP Event collector, if you are unsure
    	// set this to '1'.
    	batchSize   int
    	payloadType string
    
    	// store to persist and replay the logs to the target
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractBehavior.java

        protected String[] toStringArray(final Object value) {
            if (value instanceof String[]) {
                return (String[]) value;
            } else if (value instanceof List) {
                return ((List<?>) value).stream().map(v -> v.toString()).toArray(n -> new String[n]);
            }
            String str = DfTypeUtil.toString(value);
            if (str == null) {
                return null;
            }
            return new String[] { str };
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/es/config/allcommon/EsAbstractBehavior.java

        protected String[] toStringArray(final Object value) {
            if (value instanceof String[]) {
                return (String[]) value;
            } else if (value instanceof List) {
                return ((List<?>) value).stream().map(v -> v.toString()).toArray(n -> new String[n]);
            }
            String str = DfTypeUtil.toString(value);
            if (str == null) {
                return null;
            }
            return new String[] { str };
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/io/BaseEncodingTest.java

              fail("Expected DecodingException");
            } catch (DecodingException expected) {
              // Don't assert on the expectedMessage; the messages for exceptions thrown from the
              // decoding stream may differ from the messages for the decode methods.
            } catch (IOException e) {
              fail("Expected DecodingException but got: " + e);
            }
          }
        };
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 16:27:30 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  7. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultWagonManager.java

                for (String extension : checksums.keySet()) {
                    // TODO shouldn't need a file intermediary - improve wagon to take a stream
                    File temp = File.createTempFile("maven-artifact", null);
                    temp.deleteOnExit();
                    byte[] bytes = sums.get(extension).getBytes(StandardCharsets.UTF_8);
                    Files.write(
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 29.9K bytes
    - Viewed (0)
  8. common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto

      // Defaults to everything.
      // +optional
      optional string fieldSelector = 2;
    
      // Watch for changes to the described resources and return them as a stream of
      // add, update, and remove notifications. Specify resourceVersion.
      // +optional
      optional bool watch = 3;
    
      // allowWatchBookmarks requests watch events with type "BOOKMARK".
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/math/StatsAccumulatorTest.java

    import static com.google.common.truth.Truth.assertThat;
    import static com.google.common.truth.Truth.assertWithMessage;
    import static java.lang.Math.sqrt;
    import static java.util.stream.DoubleStream.concat;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.collect.ImmutableList;
    import com.google.common.math.StatsTesting.ManyValues;
    import com.google.common.primitives.Doubles;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 23 16:45:30 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  10. src/archive/tar/reader_test.go

    	}
    
    	data1, data2, pax, sparse := ss[0], ss[1], ss[2], ss[3]
    	data2 += strings.Repeat("\x00", 10*512)
    	trash := strings.Repeat("garbage ", 64) // Exactly 512 bytes
    
    	vectors := []struct {
    		input string // Input stream
    		cnt   int    // Expected number of headers read
    		err   error  // Expected error outcome
    	}{
    		{"", 0, io.EOF}, // Empty file is a "valid" tar file
    		{data1[:511], 0, io.ErrUnexpectedEOF},
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 03 15:48:09 UTC 2024
    - 46.9K bytes
    - Viewed (0)
Back to top