}

  /** Checks that #drain() invocations behave correctly for a drained (empty) queue. */
  private void assertDrained(BlockingQueue<Object> q) {
    assertThat(q.peek()).isNull();
    assertInterruptibleDrained(q);
    assertUninterruptibleDrained(q);
  }

  private void assertInterruptibleDrained(BlockingQueue<Object> q) {

        // Should be: 4 (nextOffset) + 4 (action) + 4 (nameLength) + fileName bytes
        int expectedBytes = 12 + (fileName.length() * 2); // Unicode is 2 bytes per char
        assertEquals(expectedBytes, bytesRead);
    }

    @Test
    @DisplayName("Test getAction returns correct value")
    void testGetAction() throws SMBProtocolDecodingException {

    void testSetURLStreamHandlerFactory_ThrowsIllegalStateExceptionOnSecondAttempt() {
        // This test ensures that attempting to set the URLStreamHandlerFactory more than once
        // throws an IllegalStateException as per the contract.
        URLStreamHandlerFactory mockFactory1 = mock(URLStreamHandlerFactory.class);
        URLStreamHandlerFactory mockFactory2 = mock(URLStreamHandlerFactory.class);

Y al usar `Depends(scope="request")` (el valor por defecto), el código de salida después de `yield` se ejecuta después de que la response es enviada.

Puedes leer más al respecto en la documentación de [Dependencias con `yield` - Salida temprana y `scope`](../tutorial/dependencies/dependencies-with-yield.md#early-exit-and-scope).

pkg bytes, method (*Buffer) Peek(int) ([]uint8, error) #73794
pkg crypto, type Decapsulator interface { Decapsulate, Encapsulator } #75300
pkg crypto, type Decapsulator interface, Decapsulate([]uint8) ([]uint8, error) #75300
pkg crypto, type Decapsulator interface, Encapsulator() Encapsulator #75300
pkg crypto, type Encapsulator interface { Bytes, Encapsulate } #75300
pkg crypto, type Encapsulator interface, Bytes() []uint8 #75300

		buf := NewBufferString(test.buffer)
		buf.Next(test.skip)
		bytes, err := buf.Peek(test.n)
		if string(bytes) != test.expected {
			t.Errorf("expected %q, got %q", test.expected, bytes)
		}
		if err != test.err {
			t.Errorf("expected error %v, got %v", test.err, err)
		}
		if buf.Len() != len(test.buffer)-test.skip {
			t.Errorf("bad length after peek: %d, want %d", buf.Len(), len(test.buffer)-test.skip)
		}
	}
}

		return cfg, err
	}
	if replicationMaxLWorkers <= 0 || replicationMaxLWorkers > 10 {
		return cfg, config.ErrInvalidReplicationWorkersValue(nil).Msg("Number of replication workers for transfers >=128MiB should be between 1 and 10 per node")
	}

	cfg.ReplicationMaxLWorkers = replicationMaxLWorkers

	transitionWorkers, err := strconv.Atoi(env.Get(EnvAPITransitionWorkers, kvs.GetWithDefault(apiTransitionWorkers, DefaultKVS)))
	if err != nil {

	public static final field EMPTY Lokhttp3/TrailersSource;
	public abstract fun get ()Lokhttp3/Headers;
	public fun peek ()Lokhttp3/Headers;
}

public final class okhttp3/TrailersSource$Companion {
}

public final class okhttp3/TrailersSource$DefaultImpls {
	public static fun peek (Lokhttp3/TrailersSource;)Lokhttp3/Headers;
}

public abstract interface class okhttp3/WebSocket {

	// response headers. e.g, X-Minio-* or X-Amz-*.
	// Tags have also been extracted, we remove that as well.
	objInfo.UserDefined = cleanMetadata(fi.Metadata)

	// All the parts per object.
	objInfo.Parts = fi.Parts

	// Update storage class
	if fi.TransitionTier != "" {
		objInfo.StorageClass = fi.TransitionTier
	} else if sc, ok := fi.Metadata[xhttp.AmzStorageClass]; ok {

        for discussion_edge in discussion_edges:
            discussion_nodes.append(discussion_edge.node)
        last_edge = discussion_edges[-1]
        # Handle GitHub secondary rate limits, requests per minute
        time.sleep(settings.sleep_interval)
        discussion_edges = get_graphql_question_discussion_edges(
            settings=settings, after=last_edge.cursor
        )
    return discussion_nodes