Search Options

Results per page
Sort
Preferred Languages
Advance

Results 741 - 750 of 4,587 for okhttp (0.03 sec)

  1. cmd/data-scanner_test.go

    	}
    	fivs := make([]FileInfo, 5)
    	objInfos := make([]ObjectInfo, 5)
    	objRetentionMeta := make(map[string]string)
    	objRetentionMeta[strings.ToLower(xhttp.AmzObjectLockMode)] = string(objectlock.RetCompliance)
    	// Set retain until date 12 hours into the future
    	objRetentionMeta[strings.ToLower(xhttp.AmzObjectLockRetainUntilDate)] = amztime.ISO8601Format(now.Add(12 * time.Hour))
    	/*
    		objInfos:
    		version stack for obj-1
    		v5 uuid-5 modTime
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  2. cmd/event-notification.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"fmt"
    	"net/url"
    	"runtime"
    	"strings"
    	"sync"
    
    	"github.com/minio/minio/internal/crypto"
    	"github.com/minio/minio/internal/event"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/pubsub"
    	"github.com/minio/pkg/v3/policy"
    )
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  3. okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.sse.internal
    
    import assertk.assertThat
    import assertk.assertions.isEmpty
    import assertk.assertions.isEqualTo
    import java.util.ArrayDeque
    import java.util.Deque
    import okio.Buffer
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.Test
    
    class ServerSentEventIteratorTest {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/cache2/FileOperatorTest.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.internal.cache2
    
    import assertk.assertThat
    import assertk.assertions.isEqualTo
    import java.io.File
    import java.io.RandomAccessFile
    import java.util.Random
    import kotlin.test.assertFailsWith
    import okio.Buffer
    import okio.ByteString
    import okio.ByteString.Companion.encodeUtf8
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  5. samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java

    package okhttp3.recipes;
    
    import java.util.concurrent.TimeUnit;
    import okhttp3.OkHttpClient;
    import okhttp3.Request;
    import okhttp3.Response;
    import okhttp3.WebSocket;
    import okhttp3.WebSocketListener;
    import okio.ByteString;
    
    public final class WebSocketEcho extends WebSocketListener {
      private void run() {
        OkHttpClient client = new OkHttpClient.Builder()
            .readTimeout(0,  TimeUnit.MILLISECONDS)
            .build();
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Apr 04 11:40:21 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  6. cmd/xl-storage-format_test.go

    		ModTime:          time.Now(),
    		Size:             1234456,
    		Mode:             0,
    		Metadata: map[string]string{
    			xhttp.AmzRestore:                 "FAILED",
    			xhttp.ContentMD5:                 mustGetUUID(),
    			xhttp.AmzBucketReplicationStatus: "PENDING",
    			xhttp.ContentType:                "application/json",
    		},
    		Parts: []ObjectPartInfo{
    			{
    				Number:     1,
    				Size:       1234345,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  7. cmd/testdata/xl-meta-merge.zip

    ¦€8 º²„„¾„8 ¨²¬¬ ªˆ¦< òˆ †Š€€¾„ˆ† ¬²¸ªbìbˆ½­‘7µ«¿7⺢”¾¼ Æ ¦¾º€¢ˆ²¤¸ª ¦¸ZŠ¿7‘Ÿ©“¢®ª †ª„Œ²¦ª†< 쾸¸¾Ž ˆ°ª ú²¼òþ 渲ª¼ˆ ÖŠ²¦ †ˆ¢„ˆ LÔ>0Š´ŸF]è>…hNsè£ ‰ ¾¦†>º²¼²¾>¸²¼Š Ú„ŽtVxZIˆ»/vf®eeè¨}í¡}uNÜM|£qmTSs•~ýôc}qï½^_ZOB“ãep¼´•]}Ziož†<t X ð¼¹ByT² 8—ú²¼òþttÊ€®„¢¨ª† „ª‚в`ª LVxNÕ†¯Ÿp\ mqò gñëGs ÷Ö³ocòQQ¿rm|eEÕm•~ûnAT-kDQ¾ ‘_i^qé ¢¸¸Äö`¢†ºµ`SN¾,WÙqJ°_² ]þ8Rto ž\q¡²¦< "¾ R|RtW†£­bô°ocòšk{1server—÷]`a[©~mhe} I©Fû`yÈŸ@Zå¾–rq«mqns{Š jÜv 3 —Š ¹ m^qï ²¤gË Dü üþÈê „ª‚ŠV„Ž^ÜNL}„•­f\2u}t¸]W1}qÖpO^³_qòsc•\i\wQÕc•jaòçXŸ}µ­$Ö/...
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  8. src/main/assemblies/files/fess.in.sh

    fi
    
    # set to headless, just in case
    FESS_JAVA_OPTS="$FESS_JAVA_OPTS -Djava.awt.headless=true"
    
    # maximum # keep-alive connections to maintain at once
    FESS_JAVA_OPTS="$FESS_JAVA_OPTS -Dhttp.maxConnections=20"
    
    # Force the JVM to use IPv4 stack
    if [ "x$FESS_USE_IPV4" != "x" ]; then
      FESS_JAVA_OPTS="$FESS_JAVA_OPTS -Djava.net.preferIPv4Stack=true"
    fi
    
    FESS_JAVA_OPTS="$FESS_JAVA_OPTS -Djna.nosys=true"
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Jan 15 06:32:15 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt

     */
    package okhttp3.internal.concurrent
    
    import assertk.assertThat
    import assertk.assertions.containsExactly
    import assertk.assertions.containsExactlyInAnyOrder
    import assertk.assertions.isEmpty
    import assertk.assertions.isEqualTo
    import assertk.assertions.isSameAs
    import java.util.concurrent.RejectedExecutionException
    import kotlin.test.assertFailsWith
    import okhttp3.TestLogHandler
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 23K bytes
    - Viewed (0)
  10. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/CertificateAdapters.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.tls.internal.der
    
    import java.math.BigInteger
    import java.net.ProtocolException
    import okio.ByteString
    
    /**
     * ASN.1 adapters adapted from the specifications in [RFC 5280][rfc_5280].
     *
     * [rfc_5280]: https://tools.ietf.org/html/rfc5280
     */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 13.6K bytes
    - Viewed (0)
Back to top