assertThat(collection.size()).isEqualTo(varargs.length);
    for (Object obj : varargs) {
      assertThat(collection.contains(obj)).isTrue();
    }
    assertThat(ImmutableList.copyOf(collection.iterator())).containsExactlyElementsIn(varargs);
  }

  static final Stats MANY_VALUES_STATS_ITERABLE = Stats.of(MANY_VALUES);
  static final Stats MANY_VALUES_STATS_ITERATOR = Stats.of(MANY_VALUES.iterator());
  static final Stats MANY_VALUES_STATS_SNAPSHOT = buildManyValuesStatsSnapshot();
  static final Stats LARGE_VALUES_STATS = Stats.of(LARGE_VALUES);
  static final Stats OTHER_MANY_VALUES_STATS = Stats.of(OTHER_MANY_VALUES);

        assertNotNull(result, "getAnchorSet should not return null for valid string");
        assertEquals(1, result.size());

        RequestData requestData = result.iterator().next();
        assertEquals("http://example.com", requestData.getUrl());
    }

    /**
     * Test getAnchorSet with blank string
     */
    @Test

        } catch (final IOException ioe) {
            log.debug("doNetShareEnum failed", ioe);
            throw new SmbException(u.toString(), ioe);
        }
        return new ShareEnumIterator(parent, set.iterator(), ff);
    }

    @SuppressWarnings("resource")
    static CloseableIterator<SmbResource> doEnum(final SmbFile parent, String wildcard, int searchAttributes, final ResourceNameFilter fnf,

                }
            }
            if (!list.isEmpty()) {
                list.sort(getPriorityComparator());
                //noinspection unchecked
                return () -> (Q) getInstance(list.iterator().next());
            } else if (dep.optional()) {
                return () -> null;
            } else {
                throw new DIException("No binding to construct an instance for key "

            throw new NoAvailableChannelException("No healthy channels available");
        }
        
        if (availableChannels.size() == 1) {
            return availableChannels.iterator().next();
        }
        
        switch (strategy) {
            case ROUND_ROBIN:
                return selectRoundRobin(availableChannels);
                
            case LEAST_LOADED:

      if (connections.isEmpty()) cleanupQueue.cancelAll()
      true
    } else {
      scheduleCloser()
      false
    }
  }

  fun evictAll() {
    val i = connections.iterator()
    while (i.hasNext()) {
      val connection = i.next()
      val socketToClose =
        connection.withLock {
          if (connection.calls.isEmpty()) {
            i.remove()

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

### `StreamingResponse` { #streamingresponse }

Nimmt einen asynchronen Generator oder einen normalen Generator/Iterator (eine Funktion mit `yield`) und streamt den Responsebody.

{* ../../docs_src/custom_response/tutorial007_py310.py hl[3,16] *}

/// note | Technische Details

      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()

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

### `StreamingResponse` { #streamingresponse }

Bir async generator veya normal generator/iterator (içinde `yield` olan bir fonksiyon) alır ve response body’yi stream eder.

{* ../../docs_src/custom_response/tutorial007_py310.py hl[3,16] *}

/// note | Teknik Detaylar