Package com.hazelcast.jet.core
Class ResettableSingletonTraverser<T>
- java.lang.Object
-
- com.hazelcast.jet.core.ResettableSingletonTraverser<T>
-
- Type Parameters:
T
- item type
- All Implemented Interfaces:
Traverser<T>
,java.util.function.Consumer<T>
public class ResettableSingletonTraverser<T> extends java.lang.Object implements Traverser<T>, java.util.function.Consumer<T>
Traverses over a single item which can be set from the outside, by using this traverser as aConsumer<T>
. Another item can be set at any time and the subsequentnext()
call will consume it. However, if this traverser already has an item, it is illegal to set another one before consuming it.See
AppendableTraverser
if you have more items to traverse.- Since:
- Jet 3.0
-
-
Constructor Summary
Constructors Constructor Description ResettableSingletonTraverser()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
accept(T item)
Resets this traverser so that the followingnext()
call will return the item supplied here.T
next()
Returns the next item, removing it from this traverser.
-
-
-
Method Detail
-
next
public T next()
Description copied from interface:Traverser
Returns the next item, removing it from this traverser. If no item is available, returnsnull
. If this traverser is null-terminated, getting anull
means it's exhausted and will keep returningnull
forever. Otherwise, trying again later may produce one.
-
accept
public void accept(@Nullable T item)
Resets this traverser so that the followingnext()
call will return the item supplied here. If the traverser already has an item, it is illegal to call this method until that item is consumed by callingnext()
.- Specified by:
accept
in interfacejava.util.function.Consumer<T>
- Parameters:
item
- the item to return fromnext()
-
-