Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1991 - 2000 of 2,345 for Add (0.02 sec)

  1. guava-tests/test/com/google/common/io/FilesTest.java

            new LineProcessor<List<String>>() {
              List<String> collector = new ArrayList<>();
    
              @Override
              public boolean processLine(String line) {
                collector.add(line);
                return true;
              }
    
              @Override
              public List<String> getResult() {
                return collector;
              }
            };
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  2. guava/src/com/google/common/io/ByteStreams.java

        if (b == -1) {
          return bytes;
        }
    
        // the stream was longer, so read the rest normally
        Queue<byte[]> bufs = new ArrayDeque<>(TO_BYTE_ARRAY_DEQUE_SIZE + 2);
        bufs.add(bytes);
        bufs.add(new byte[] {(byte) b});
        return toByteArrayInternal(in, bufs, bytes.length + 1);
      }
    
      /**
       * Reads and discards data from the given {@code InputStream} until the end of the stream is
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 29.7K bytes
    - Viewed (0)
  3. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt

       * Execute [block] with a new namespace for type hints. Type hints from the enclosing type are no
       * longer usable by the current type's members.
       */
      fun <T> withTypeHint(block: () -> T): T {
        typeHintStack.add(null)
        try {
          return block()
        } finally {
          typeHintStack.removeAt(typeHintStack.size - 1)
        }
      }
    
      fun readBoolean(): Boolean {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/idn/IdnaMappingTable.kt

            val codepointDelta = (b1 and 0xF shl 14) or (b2 shl 7) or b3
            sink.writeUtf8CodePoint(codePoint - codepointDelta)
          }
          in 80..95 -> {
            // Mapped inline as codePoint delta to add
            val b2 = ranges[rangesIndex + 2].code
            val b3 = ranges[rangesIndex + 3].code
    
            val codepointDelta = (b1 and 0xF shl 14) or (b2 shl 7) or b3
            sink.writeUtf8CodePoint(codePoint + codepointDelta)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Apr 02 11:39:58 UTC 2024
    - 9K bytes
    - Viewed (0)
  5. compat/maven-compat/src/test/java/org/apache/maven/artifact/AbstractArtifactComponentTestCase.java

        protected List<ArtifactRepository> remoteRepositories() throws Exception {
            List<ArtifactRepository> remoteRepositories = new ArrayList<>();
    
            remoteRepositories.add(remoteRepository());
    
            return remoteRepositories;
        }
    
        // ----------------------------------------------------------------------
        // Test artifact generation for unit tests
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  6. internal/event/target/amqp.go

    	data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}})
    	if err != nil {
    		return err
    	}
    
    	headers := make(amqp091.Table)
    	// Add more information here as required, but be aware to not overload headers
    	headers["minio-bucket"] = eventData.S3.Bucket.Name
    	headers["minio-event"] = eventData.EventName.String()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  7. cmd/signature-v4_test.go

    		},
    		// (6) Should error if the request is not ready yet, ie X-Amz-Date is in the future.
    		{
    			queryParams: map[string]string{
    				"X-Amz-Algorithm":      signV4Algorithm,
    				"X-Amz-Date":           now.Add(1 * time.Hour).Format(iso8601Format),
    				"X-Amz-Expires":        "60",
    				"X-Amz-Signature":      "badsignature",
    				"X-Amz-SignedHeaders":  "host;x-amz-content-sha256;x-amz-date",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  8. okhttp-testing-support/src/main/kotlin/okhttp3/testing/PlatformRule.kt

          expectFailure(platformMatches(LOOM_PROPERTY))
        }
    
        private fun expectFailure(
          versionMatcher: Matcher<out Any>,
          failureMatcher: Matcher<out Any> = anything(),
        ) {
          versionChecks.add(Pair(versionMatcher, failureMatcher))
        }
    
        fun platformMatches(platform: String): Matcher<Any> =
          object : BaseMatcher<Any>() {
            override fun describeTo(description: Description) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 15.3K bytes
    - Viewed (1)
  9. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

       */
      public void testTransitionRace() throws TimeoutException {
        for (int k = 0; k < 1000; k++) {
          List<Service> services = Lists.newArrayList();
          for (int i = 0; i < 5; i++) {
            services.add(new SnappyShutdownService(i));
          }
          ServiceManager manager = new ServiceManager(services);
          manager.startAsync().awaitHealthy();
          manager.stopAsync().awaitStopped(10, SECONDS);
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/smb1/SmbTransport.java

                            return conn;
                        }
                    }
                }
    
                conn = new SmbTransport( address, port, localAddr, localPort );
                CONNECTIONS.add( 0, conn );
            }
    
            return conn;
        }
    
        class ServerData {
            byte flags;
            int flags2;
            int maxMpxCount;
            int maxBufferSize;
            int sessionKey;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 31.2K bytes
    - Viewed (0)
Back to top