com.azure.core.util

Class IterableStream<T>

java.lang.Object

com.azure.core.util.IterableStream<T>

Type Parameters:

T - The type of value in this Iterable.

All Implemented Interfaces:

Iterable<T>

Direct Known Subclasses:

ContinuablePagedIterable

public class IterableStream<T>
extends Object
implements Iterable<T>

This class provides utility to iterate over values using standard 'for-each' style loops or to convert them into a Stream and operate in that fashion.

Code sample using Stream

// process the stream
myIterableStream.stream().forEach(resp -> {
    if (resp.getStatusCode() == HttpURLConnection.HTTP_OK) {
        System.out.printf("Response headers are %s. Url %s%n", resp.getDeserializedHeaders(),
            resp.getRequest().getUrl());
        resp.getElements().forEach(value -> System.out.printf("Response value is %d%n", value));
    }
});

Code sample using Iterator

// Iterate over iterator
for (PagedResponseBase<String, Integer> resp : myIterableStream) {
    if (resp.getStatusCode() == HttpURLConnection.HTTP_OK) {
        System.out.printf("Response headers are %s. Url %s%n", resp.getDeserializedHeaders(),
            resp.getRequest().getUrl());
        resp.getElements().forEach(value -> System.out.printf("Response value is %d%n", value));
    }
}

Code sample using Stream and filter

// process the stream
myIterableStream.stream().filter(resp -> resp.getStatusCode() == HttpURLConnection.HTTP_OK)
    .limit(10)
    .forEach(resp -> {
        System.out.printf("Response headers are %s. Url %s%n", resp.getDeserializedHeaders(),
            resp.getRequest().getUrl());
        resp.getElements().forEach(value -> System.out.printf("Response value is %d%n", value));
    });

See Also:

Iterable

Constructor Summary

Constructors

Constructor and Description
IterableStream(Flux<T> flux) Creates an instance with the given Flux.
IterableStream(Iterable<T> iterable) Creates an instance with the given Iterable.

Method Summary

Modifier and Type	Method and Description
Iterator<T>	iterator() Utility function to provide Iterator of value T.
static <T> IterableStream<T>	of(Iterable<T> iterable) Creates an IterableStream from an Iterable.
Stream<T>	stream() Utility function to provide Stream of value T.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

IterableStream

public IterableStream(Flux<T> flux)

Creates an instance with the given Flux.

Parameters:

flux - Flux of items to iterate over.

Throws:

NullPointerException - If flux is null.

IterableStream

public IterableStream(Iterable<T> iterable)

Creates an instance with the given Iterable.

Parameters:

iterable - Collection of items to iterate over.

Throws:

NullPointerException - If iterable is null.

Method Detail

stream

public Stream<T> stream()

Utility function to provide Stream of value T.

Returns:

Stream of value T.

iterator

public Iterator<T> iterator()

Utility function to provide Iterator of value T.

Specified by:

iterator in interface Iterable<T>

Returns:

Iterator of value T.

of

public static <T> IterableStream<T> of(Iterable<T> iterable)

Creates an IterableStream from an Iterable.

An empty IterableStream will be returned if the input iterable is null.

Type Parameters:

T - The type of value in this Iterable.

Parameters:

iterable - Collection of items to iterate over.

Returns:

An IterableStream based on the passed collection.