Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 298 for unwrap (0.09 sec)

  1. src/main/java/jcifs/smb/SmbEnumerationUtil.java

                        list.add(n.getName());
                    }
                }
                return list.toArray(new String[list.size()]);
            }
            catch ( CIFSException e ) {
                throw SmbException.wrap(e);
            }
        }
    
    
        static SmbFile[] listFiles ( SmbFile root, String wildcard, int searchAttributes, final SmbFilenameFilter fnf, final SmbFileFilter ff )
                throws SmbException {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sat Jul 20 08:41:19 UTC 2019
    - 12.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/eventbus/SubscriberRegistry.java

             * simply rethrow an exception (e.getCause()) that may in rare cases have come from another
             * thread. To accomplish both goals, we wrap that IllegalArgumentException in a new
             * instance.
             */
            throw new IllegalArgumentException(e.getCause().getMessage(), e.getCause());
          }
          /*
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 15:16:45 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

       * the request completes normally or when it fails due to an exception, in which case [e] should
       * be non-null.
       *
       * If the exchange was canceled or timed out, this will wrap [e] in an exception that provides
       * that additional context. Otherwise [e] is returned as-is.
       */
      internal fun <E : IOException?> messageDone(
        exchange: Exchange,
        requestDone: Boolean,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/HashMultimap.java

     *
     * <p>This class is not threadsafe when any concurrent operations update the multimap. Concurrent
     * read operations will work correctly if the last write <i>happens-before</i> any reads. To allow
     * concurrent update operations, wrap your multimap with a call to {@link
     * Multimaps#synchronizedSetMultimap}.
     *
     * <p><b>Warning:</b> Do not modify either a key <i>or a value</i> of a {@code HashMultimap} in a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 10:02:49 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt

      private val handshakeCertificates = platform.localhostHandshakeCertificates()
    
      private var client =
        clientTestRule.newClientBuilder()
          .eventListenerFactory(clientTestRule.wrap(listener))
          .build()
    
      private lateinit var server: MockWebServer
    
      @BeforeEach
      fun setUp(server: MockWebServer) {
        this.server = server
        platform.assumeNotOpenJSSE()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/io/SourceSinkFactories.java

          }
        };
      }
    
      private static class StringSourceFactory implements CharSourceFactory {
    
        @Override
        public CharSource createSource(String data) throws IOException {
          return CharSource.wrap(data);
        }
    
        @Override
        public String getExpected(String data) {
          return data;
        }
    
        @Override
        public void tearDown() throws IOException {}
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 17.7K bytes
    - Viewed (0)
  7. cmd/object-multipart-handlers.go

    	if isCompressed {
    		wantEncryption := crypto.Requested(r.Header) || isEncrypted
    		s2c, cb := newS2CompressReader(reader, actualPartSize, wantEncryption)
    		idxCb = cb
    		defer s2c.Close()
    		reader = etag.Wrap(s2c, reader)
    		length = -1
    	}
    
    	srcInfo.Reader, err = hash.NewReader(ctx, reader, length, "", "", actualPartSize)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  8. internal/http/server.go

    		if listenErrs[i] != nil {
    			listenErrCallback(srv.Addrs[i], listenErrs[i])
    		} else {
    			interfaceFound = true
    		}
    	}
    	if !interfaceFound {
    		return nil, errors.New("no available interface found")
    	}
    
    	// Wrap given handler to do additional
    	// * return 503 (service unavailable) if the server in shutdown.
    	wrappedHandler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		// If server is in shutdown.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/ImmutableClassToInstanceMap.java

            T value = entry.getValue();
            mapBuilder.put(type, cast(type, value));
          }
          return this;
        }
    
        private static <T> T cast(Class<T> type, Object value) {
          return Primitives.wrap(type).cast(value);
        }
    
        /**
         * Returns a new immutable class-to-instance map containing the entries provided to this
         * builder.
         *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 10 21:56:03 UTC 2023
    - 7.1K bytes
    - Viewed (0)
  10. guava/src/com/google/common/hash/AbstractStreamingHasher.java

        Java8Compatibility.flip(bb);
        process(bb);
      }
    
      @Override
      @CanIgnoreReturnValue
      public final Hasher putBytes(byte[] bytes, int off, int len) {
        return putBytesInternal(ByteBuffer.wrap(bytes, off, len).order(ByteOrder.LITTLE_ENDIAN));
      }
    
      @Override
      @CanIgnoreReturnValue
      public final Hasher putBytes(ByteBuffer readBuffer) {
        ByteOrder order = readBuffer.order();
        try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 15 20:59:00 UTC 2022
    - 7.1K bytes
    - Viewed (0)
Back to top