Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1101 - 1110 of 3,747 for throwIt (0.14 seconds)

  1. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

          if (actualException instanceof InterruptedException) {
            return Outcome.INTERRUPT;
          } else {
            throw new AssertionError("unexpected exception", targetException);
          }
        } catch (IllegalAccessException e) {
          throw new AssertionError("unexpected exception", e);
        }
      }
    
      private void enterSatisfyGuardAndLeaveInCurrentThread() {
        monitor.enter();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.7K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/MinMaxPriorityQueue.java

      }
    
      /**
       * Removes and returns the greatest element of this queue.
       *
       * @throws NoSuchElementException if the queue is empty
       */
      @CanIgnoreReturnValue
      public E removeLast() {
        if (isEmpty()) {
          throw new NoSuchElementException();
        }
        return removeAndGet(getMaxElementIndex());
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 13:11:08 GMT 2026
    - 34K bytes
    - Click Count (0)
  3. src/main/java/jcifs/internal/smb2/create/LeaseV1CreateContextResponse.java

         */
        public int getLeaseFlags() {
            return leaseFlags;
        }
    
        @Override
        public int decode(byte[] buffer, int bufferIndex, int len) throws SMBProtocolDecodingException {
            int start = bufferIndex;
    
            if (len < 32) {
                throw new SMBProtocolDecodingException("Lease V1 context data too short: " + len);
            }
    
            // Read lease V1 data (32 bytes)
            byte[] keyBytes = new byte[16];
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 02:21:31 GMT 2025
    - 2.8K bytes
    - Click Count (0)
  4. src/main/java/jcifs/netbios/SessionRequestPacket.java

            return dstIndex - start;
        }
    
        @Override
        int readTrailerWireFormat(final InputStream in, final byte[] buffer, int bufferIndex) throws IOException {
            final int start = bufferIndex;
            if (in.read(buffer, bufferIndex, this.length) != this.length) {
                throw new IOException("invalid session request wire format");
            }
            bufferIndex += this.calledName.readWireFormat(buffer, bufferIndex);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  5. compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/MetadataTreeNode.java

            return md == null ? "no metadata" : md.toString();
        }
    
        // ------------------------------------------------------------------
        public String graphHash() throws MetadataResolutionException {
            if (md == null) {
                throw new MetadataResolutionException(
                        "treenode without metadata, parent: " + (parent == null ? "null" : parent.toString()));
            }
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 3.9K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/collect/Collections2.java

        }
    
        return new FilteredCollection<>(checkNotNull(unfiltered), checkNotNull(predicate));
      }
    
      /**
       * Delegates to {@link Collection#contains}. Returns {@code false} if the {@code contains} method
       * throws a {@code ClassCastException} or {@code NullPointerException}.
       */
      static boolean safeContains(Collection<?> collection, @Nullable Object object) {
        checkNotNull(collection);
        try {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 22.6K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

     */
    @J2ktIncompatible // threads
    @GwtIncompatible // threads
    @NullUnmarked
    public class AtomicLongMapBasherTest extends TestCase {
      private final Random random = new Random(301);
    
      public void testModify_basher() throws Exception {
        int nTasks = 3000;
        int nThreads = 100;
        int getsPerTask = 1000;
        int deltaRange = 10000;
        String key = "key";
    
        AtomicLongMap<String> map = AtomicLongMap.create();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  8. src/main/java/jcifs/internal/smb2/create/LeaseV2CreateContextResponse.java

         */
        public int getEpoch() {
            return epoch;
        }
    
        @Override
        public int decode(byte[] buffer, int bufferIndex, int len) throws SMBProtocolDecodingException {
            int start = bufferIndex;
    
            if (len < 52) {
                throw new SMBProtocolDecodingException("Lease V2 context data too short: " + len);
            }
    
            // Read lease V2 data (52 bytes)
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 02:21:31 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/collect/CompactHashSet.java

      }
    
      @J2ktIncompatible
      private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        stream.writeInt(size());
        for (E e : this) {
          stream.writeObject(e);
        }
      }
    
      @SuppressWarnings("unchecked")
      @J2ktIncompatible
      private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
        stream.defaultReadObject();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 23.9K bytes
    - Click Count (0)
  10. build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/AlphabeticalAcceptedApiChangesTask.kt

    import org.gradle.api.tasks.TaskAction
    import java.io.File
    
    
    /**
     * This [Task][org.gradle.api.Task] checks that the contents of a given accepted API changes files
     * are present in alphabetical order (by type, then member), and throws an exception and reports
     * any changes that are not.
     */
    @CacheableTask
    abstract class AlphabeticalAcceptedApiChangesTask : AbstractAcceptedApiChangesMaintenanceTask() {
    
        @TaskAction
        fun execute() {
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Fri Nov 29 14:03:44 GMT 2024
    - 2.5K bytes
    - Click Count (0)
Back to Top