org.openjdk.jmc.common.item

Class ItemCollectionToolkit.StreamBackedItemCollection

java.lang.Object

org.openjdk.jmc.common.item.ItemCollectionToolkit.StreamBackedItemCollection

All Implemented Interfaces:

java.lang.Iterable<IItemIterable>, IItemCollection

Enclosing class:

ItemCollectionToolkit

private static class ItemCollectionToolkit.StreamBackedItemCollection
extends java.lang.Object
implements IItemCollection

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Set<IRange<IQuantity>>	chunkRanges
private java.util.function.Supplier<java.util.stream.Stream<IItemIterable>>	items

Constructor Summary

Constructors

Constructor and Description
StreamBackedItemCollection(java.util.function.Supplier<java.util.stream.Stream<IItemIterable>> items, java.util.Set<IRange<IQuantity>> chunkRanges)

Method Summary

Modifier and Type	Method and Description
ItemCollectionToolkit.StreamBackedItemCollection	apply(IItemFilter filter) Creates a new item collection with all items in this collection that pass through the filter.
<V,C extends IItemConsumer<C>> V	getAggregate(IAggregator<V,C> aggregator) Calculates an aggregated value for the items in this collection.
java.util.Set<IRange<IQuantity>>	getUnfilteredTimeRanges() Returns a set of IRange representations of the time ranges represented by this item collection.
boolean	hasItems()
java.util.Iterator<IItemIterable>	iterator()
java.util.Spliterator<IItemIterable>	spliterator()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.openjdk.jmc.common.item.IItemCollection

parallelStream, stream, values

Methods inherited from interface java.lang.Iterable

forEach

Field Detail

items

private final java.util.function.Supplier<java.util.stream.Stream<IItemIterable>> items

chunkRanges

private final java.util.Set<IRange<IQuantity>> chunkRanges

Constructor Detail

StreamBackedItemCollection

StreamBackedItemCollection(java.util.function.Supplier<java.util.stream.Stream<IItemIterable>> items,
                           java.util.Set<IRange<IQuantity>> chunkRanges)

Method Detail

iterator

public java.util.Iterator<IItemIterable> iterator()

Specified by:

iterator in interface java.lang.Iterable<IItemIterable>

spliterator

public java.util.Spliterator<IItemIterable> spliterator()

Specified by:

spliterator in interface java.lang.Iterable<IItemIterable>

apply

public ItemCollectionToolkit.StreamBackedItemCollection apply(IItemFilter filter)

Description copied from interface: IItemCollection

Creates a new item collection with all items in this collection that pass through the filter. The collection may be eagerly or lazily evaluated.

Specified by:

apply in interface IItemCollection

Parameters:

filter - the filter to use when selecting items for the new collection

Returns:

a new collection of items

getAggregate

public <V,C extends IItemConsumer<C>> V getAggregate(IAggregator<V,C> aggregator)

Description copied from interface: IItemCollection

Calculates an aggregated value for the items in this collection.

Specified by:

getAggregate in interface IItemCollection

Type Parameters:

V - aggregate result value type

C - Item consumer type. See IAggregator.

Returns:

the aggregated value

hasItems

public boolean hasItems()

Specified by:

hasItems in interface IItemCollection

Returns:

true if the collections contains items, false otherwise

getUnfilteredTimeRanges

public java.util.Set<IRange<IQuantity>> getUnfilteredTimeRanges()

Description copied from interface: IItemCollection

Returns a set of IRange representations of the time ranges represented by this item collection. This set is not affected by any filtering operations on the item collection since its use is to show the time ranges in which events could possibly have been occurred.

Specified by:

getUnfilteredTimeRanges in interface IItemCollection

Returns:

a set of IRange objects representing the time ranges available in this IItemCollection