Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 781 - 790 of 5,478 for newE (0.02 seconds)

  1. compat/maven-compat/src/test/java/org/apache/maven/repository/legacy/StringWagon.java

                inputData.setInputStream(new ByteArrayInputStream(content.getBytes(StandardCharsets.UTF_8)));
            } else {
                throw new ResourceDoesNotExistException("No content provided for " + resource.getName());
            }
        }
    
        @Override
        public void fillOutputData(OutputData outputData) throws TransferFailedException {
            outputData.setOutputStream(new ByteArrayOutputStream());
        }
    
        @Override
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 3K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

            .add(new Striped.LargeLazyStriped<Lock>(50, LOCK_SUPPLER))
            .add(new Striped.LargeLazyStriped<Lock>(64, LOCK_SUPPLER))
            .add(new Striped.SmallLazyStriped<Semaphore>(50, SEMAPHORE_SUPPLER))
            .add(new Striped.SmallLazyStriped<Semaphore>(64, SEMAPHORE_SUPPLER))
            .add(new Striped.LargeLazyStriped<Semaphore>(50, SEMAPHORE_SUPPLER))
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 18:19:59 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

            .add(new Striped.LargeLazyStriped<Lock>(50, LOCK_SUPPLER))
            .add(new Striped.LargeLazyStriped<Lock>(64, LOCK_SUPPLER))
            .add(new Striped.SmallLazyStriped<Semaphore>(50, SEMAPHORE_SUPPLER))
            .add(new Striped.SmallLazyStriped<Semaphore>(64, SEMAPHORE_SUPPLER))
            .add(new Striped.LargeLazyStriped<Semaphore>(50, SEMAPHORE_SUPPLER))
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 18:19:59 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  4. src/main/java/jcifs/smb/MultiChannelManager.java

        private final ConcurrentMap<String, ChannelGroup> sessionChannels = new ConcurrentHashMap<>();
        private final ExecutorService channelExecutor;
        private final ScheduledExecutorService healthCheckExecutor;
    
        // Statistics
        private final AtomicLong totalRequests = new AtomicLong(0);
        private final AtomicLong totalChannelsCreated = new AtomicLong(0);
    
        /**
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 20.5K bytes
    - Click Count (0)
  5. src/test/java/org/codelibs/core/misc/Base64UtilTest.java

            final byte[] utf8Decoded = Base64Util.decode(utf8Encoded);
            assertEquals("Round trip should preserve UTF-8 data", utf8Text, new String(utf8Decoded, "UTF-8"));
    
            // Test with binary data
            final byte[] binaryData = new byte[] { 0, 1, 2, 3, 127, (byte) 128, (byte) 255 };
            final String binaryEncoded = Base64Util.encode(binaryData);
            final byte[] binaryDecoded = Base64Util.decode(binaryEncoded);
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Sat Nov 22 11:21:59 GMT 2025
    - 6K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/app/web/api/admin/backup/ApiAdminBackupAction.java

                    return asStream(id).contentTypeOctetStream().stream(out -> {
                        try (final ByteArrayOutputStream baos = new ByteArrayOutputStream()) {
                            ComponentUtil.getSystemProperties().store(baos, id);
                            try (final InputStream in = new ByteArrayInputStream(baos.toByteArray())) {
                                out.write(in);
                            }
                        }
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  7. guava/src/com/google/common/collect/ImmutableSet.java

      }
    
      @Override
      @J2ktIncompatible
        Object writeReplace() {
        return new SerializedForm(toArray());
      }
    
      @J2ktIncompatible
        private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      /**
       * Returns a new builder. The generated builder is equivalent to the builder created by the {@link
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Nov 07 16:09:47 GMT 2025
    - 35.3K bytes
    - Click Count (0)
  8. src/test/java/jcifs/internal/smb2/lease/Smb2LeaseKeyTest.java

        }
    
        @Test
        @DisplayName("Should reject wrong size key")
        void testWrongSizeKey() {
            assertThrows(IllegalArgumentException.class, () -> new Smb2LeaseKey(new byte[15]));
            assertThrows(IllegalArgumentException.class, () -> new Smb2LeaseKey(new byte[17]));
            assertThrows(IllegalArgumentException.class, () -> new Smb2LeaseKey(new byte[0]));
        }
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 21 00:16:17 GMT 2025
    - 6K bytes
    - Click Count (0)
  9. src/test/java/org/codelibs/fess/suggest/index/SuggestDeleteResponseTest.java

            assertEquals(0, response.getTook());
            assertFalse(response.hasError());
        }
    
        @Test
        public void test_multipleDifferentErrors() throws Exception {
            List<Throwable> errors = new ArrayList<>();
            errors.add(new Exception("Exception error"));
            errors.add(new RuntimeException("Runtime error"));
    Created: Sat Dec 20 13:04:59 GMT 2025
    - Last Modified: Thu Nov 13 00:40:54 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/app/web/api/admin/dict/stemmeroverride/ApiAdminDictStemmeroverrideAction.java

            body.dictId = dictId;
            validateApi(body, messages -> {});
            final StemmerOverridePager pager = copyBeanToNewBean(body, StemmerOverridePager.class);
            return asJson(
                    new ApiResult.ApiConfigsResponse<EditBody>().settings(stemmerOverrideService.getStemmerOverrideList(body.dictId, pager)
                            .stream()
                            .map(protwordsItem -> createEditBody(protwordsItem, dictId))
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 9.8K bytes
    - Click Count (0)
Back to Top