iterated - Code Search

src/test/java/org/codelibs/fess/crawler/transformer/FessXpathTransformerTest.java

            final Set<RequestData> childUrlList = e.getChildUrlList();
            assertEquals(1, childUrlList.size());
            assertEquals("http://example.com/foo", childUrlList.iterator().next().getUrl());
        }

        data = "<html><link rel=\"canonical\" href=\"http://example.com/foo\"><body>aaa</body></html>";
        document = getDocument(data);
        try {

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Sat Jul 19 23:49:30 UTC 2025

- 41.5K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt

            evictToRecoverBytes(dynamicTableByteCount - maxDynamicTableByteCount)
          }
        }
      }
    }

  /**
   * An HTTP/2 response cannot contain uppercase header characters and must be treated as
   * malformed.
   */
  @Throws(IOException::class)
  fun checkLowercase(name: ByteString): ByteString {
    for (i in 0 until name.size) {
      if (name[i] in 'A'.code.toByte()..'Z'.code.toByte()) {

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Mon May 05 16:01:00 UTC 2025

- 22.4K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/de/docs/advanced/custom-response.md

{* ../../docs_src/custom_response/tutorial006c.py hl[2,7,9] *}

### `StreamingResponse`

Nimmt einen asynchronen Generator oder einen normalen Generator/Iterator und streamt den Responsebody.

{* ../../docs_src/custom_response/tutorial007.py hl[2,14] *}

#### Verwendung von `StreamingResponse` mit dateiähnlichen Objekten

Registered: Sun Sep 07 07:19:17 UTC 2025

- Last Modified: Mon Nov 18 02:25:44 UTC 2024

- 13.1K bytes

- Viewed (0)

github.com/square/okhttp

mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

      serverSocket?.closeQuietly()

      val openClientSocket = openClientSockets.iterator()
      while (openClientSocket.hasNext()) {
        openClientSocket.next().closeQuietly()
        openClientSocket.remove()
      }

      val httpConnection = openConnections.iterator()
      while (httpConnection.hasNext()) {
        httpConnection.next().closeQuietly()
        httpConnection.remove()

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Sat Aug 02 20:36:00 UTC 2025

- 40.3K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/base/Strings.java

   * recognized.
   *
   * @param template a string containing zero or more {@code "%s"} placeholder sequences. {@code
   *     null} is treated as the four-character string {@code "null"}.
   * @param args the arguments to be substituted into the message template. The first argument

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Wed Aug 27 17:53:41 UTC 2025

- 12.2K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/smb1/trans/nt/SmbComNtTransactionResponseTest.java

        // Reserved bytes
        buffer[bufferIndex] = (byte) 0xFF;
        buffer[bufferIndex + 1] = (byte) 0xFF;
        buffer[bufferIndex + 2] = (byte) 0xFF;

        // Set fields with negative values (should be treated as unsigned)
        SMBUtil.writeInt4(-1, buffer, bufferIndex + 3); // Should be read as 0xFFFFFFFF
        SMBUtil.writeInt4(-100, buffer, bufferIndex + 7);
        SMBUtil.writeInt4(-1000, buffer, bufferIndex + 11);

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Thu Aug 14 05:31:44 UTC 2025

- 16.3K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

        .Builder()
        .body("c")
        .build(),
    )
    val urlC = server.url("/c")
    assertThat(get(urlC).body.string()).isEqualTo("c")

    // Confirm the iterator returns those responses...
    val i: Iterator<String> = cache.urls()
    assertThat(i.hasNext()).isTrue()
    assertThat(i.next()).isEqualTo(urlA.toString())
    assertThat(i.hasNext()).isTrue()

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Sat Aug 16 09:39:51 UTC 2025

- 113.6K bytes

- Viewed (0)

github.com/minio/minio

cmd/iam-etcd-store.go

package cmd

import (
	"context"
	"encoding/json"
	"errors"
	"path"
	"strings"
	"sync"
	"time"

	jsoniter "github.com/json-iterator/go"
	"github.com/minio/minio-go/v7/pkg/set"
	"github.com/minio/minio/internal/config"
	"github.com/minio/minio/internal/kms"
	"github.com/puzpuzpuz/xsync/v3"
	"go.etcd.io/etcd/api/v3/mvccpb"

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Fri Aug 29 02:39:48 UTC 2025

- 13.9K bytes

- Viewed (0)

github.com/minio/minio

cmd/batch-rotate.go

package cmd

import (
	"context"
	"encoding/base64"
	"fmt"
	"maps"
	"math/rand"
	"net/http"
	"runtime"
	"strconv"
	"strings"
	"time"

	jsoniter "github.com/json-iterator/go"
	"github.com/minio/minio-go/v7/pkg/tags"
	"github.com/minio/minio/internal/crypto"
	xhttp "github.com/minio/minio/internal/http"
	"github.com/minio/minio/internal/kms"
	"github.com/minio/pkg/v3/env"

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Fri Aug 29 02:39:48 UTC 2025

- 14.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/auth-handler.go

	// secret keys and generate an entirely new claim by essentially
	// hijacking the policies. We need to make sure that this is
	// based on admin credential such that token cannot be decoded
	// on the client side and is treated like an opaque value.
	claims, err := auth.ExtractClaims(token, secret)
	if err != nil {
		if subtle.ConstantTimeCompare([]byte(secret), []byte(globalActiveCred.SecretKey)) == 1 {
			return nil, errAuthentication
		}

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Fri Aug 29 02:39:48 UTC 2025

- 25.4K bytes

- Viewed (0)

Search Options