Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1111 - 1120 of 1,611 for Mangle (0.06 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/platform/Jdk8WithJettyBootPlatform.kt

          throw AssertionError("failed to get ALPN selected protocol", e)
        } catch (e: IllegalAccessException) {
          throw AssertionError("failed to get ALPN selected protocol", e)
        }
      }
    
      /**
       * Handle the methods of ALPN's ClientProvider and ServerProvider without a compile-time
       * dependency on those interfaces.
       */
      private class AlpnProvider(
        /** This peer's supported protocols. */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java

    import okhttp3.EventListener;
    import okhttp3.Handshake;
    import okhttp3.HttpUrl;
    import okhttp3.OkHttpClient;
    import okhttp3.Protocol;
    import okhttp3.Request;
    import okhttp3.Response;
    
    /**
     * This prints events for a single in-flight call. It won't work for multiple concurrent calls
     * because we don't know what callStartNanos refers to.
     */
    public final class PrintEventsNonConcurrent {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 16 23:20:49 UTC 2020
    - 5.3K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

              public void onFailure(Throwable t) {}
            },
            directExecutor());
        return closingFuture;
      }
    
      /**
       * Starts specifying how to combine {@link ClosingFuture}s into a single pipeline.
       *
       * @throws IllegalStateException if a {@code ClosingFuture} has already been derived from any of
       *     the {@code futures}, or if any has already been {@linkplain #finishToFuture() finished}
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 08 19:36:35 UTC 2024
    - 98.5K bytes
    - Viewed (0)
  4. helm/minio/templates/_helper_create_svcacct.txt

    {{- if .Values.tls.enabled }}
    scheme=https
    {{- else }}
    scheme=http
    {{- end }}
    connectToMinio $scheme
    
    {{ if .Values.svcaccts }}
    {{ $global := . }}
    # Create the svcaccts
    {{- range $idx, $svc := .Values.svcaccts }}
    echo {{ tpl .accessKey $global }} > $MINIO_ACCESSKEY_SECRETKEY_TMP
    {{- if .existingSecret }}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 28 23:20:50 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  5. src/main/webapp/js/admin/plugins/form-validator/html5.js

    "url");break;case"email":b.push("email");break;case"date":b.push("date");break;case"number":b.push("number");var i=e.attr("max"),j=e.attr("min"),k=e.attr("step");j||i?(j||(j="0"),i||(i="9007199254740992"),k||(k="1"),h["data-validation-allowing"]="range["+j+";"+i+"]",0!==j.indexOf("-")&&0!==i.indexOf("-")||(h["data-validation-allowing"]+=",negative"),(j.indexOf(".")>-1||i.indexOf(".")>-1||k.indexOf(".")>-1)&&(h["data-validation-allowing"]+=",float")):h["data-validation-allowing"]+=",float,negativ...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jan 01 05:12:47 UTC 2018
    - 2.6K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt

    import okhttp3.internal.ws.RealWebSocket
    import okio.Buffer
    import okio.ForwardingSink
    import okio.ForwardingSource
    import okio.Sink
    import okio.Source
    import okio.buffer
    
    /**
     * Transmits a single HTTP request and a response pair. This layers connection management and events
     * on [ExchangeCodec], which handles the actual I/O.
     */
    class Exchange(
      internal val call: RealCall,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  7. guava/src/com/google/common/io/Resources.java

       *
       * @param url the URL to read from
       * @param charset the charset used to decode the input stream; see {@link StandardCharsets} for
       *     helpful predefined constants
       * @param callback the LineProcessor to use to handle the lines
       * @return the output of processing the lines
       * @throws IOException if an I/O error occurs
       */
      @CanIgnoreReturnValue // some processors won't return a useful result
      @ParametricNullness
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 13:50:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  8. internal/s3select/csv/reader.go

    	if r.columnNames == nil {
    		r.columnNames = make([]string, len(csvRecord))
    		for i := range csvRecord {
    			r.columnNames[i] = fmt.Sprintf("_%v", i+1)
    		}
    	}
    
    	// If no index map, add that.
    	if r.nameIndexMap == nil {
    		r.nameIndexMap = make(map[string]int64)
    		for i := range r.columnNames {
    			r.nameIndexMap[r.columnNames[i]] = int64(i)
    		}
    	}
    	dstRec, ok := dst.(*Record)
    	if !ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  9. internal/event/targetlist.go

    	list.RLock()
    	defer list.RUnlock()
    
    	targets := []Target{}
    	for _, tgt := range list.targets {
    		targets = append(targets, tgt)
    	}
    
    	return targets
    }
    
    // List - returns available target IDs.
    func (list *TargetList) List() []TargetID {
    	list.RLock()
    	defer list.RUnlock()
    
    	keys := []TargetID{}
    	for k := range list.targets {
    		keys = append(keys, k)
    	}
    
    	return keys
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  10. internal/store/queuestore_test.go

    		}
    		items = append(items, item)
    	}
    
    	keys := store.List()
    	if len(keys) != 6 {
    		// 1 multiple + 5 single PUTs
    		t.Fatalf("expected len(keys)=6, but found %d", len(keys))
    	}
    
    	var resultItems []TestItem
    	for _, key := range keys {
    		if key.ItemCount > 1 {
    			items, err := store.GetMultiple(key)
    			if err != nil {
    				t.Fatalf("unable to get multiple items; %v", err)
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.7K bytes
    - Viewed (0)
Back to top