uk.co.strangeskies.collection

Interface Reiterator<T,R>

Type Parameters:

T - the type of event message to consume

R - the type of event message to produce

All Superinterfaces:

java.util.function.Consumer<T>, java.lang.Iterable<R>, java.util.function.Supplier<R>

public interface Reiterator<T,R>
extends java.util.function.Consumer<T>, java.util.function.Supplier<R>, java.lang.Iterable<R>

A buffer to decouple the delivery of events with their sequential consumption, such that events consumed will be queued for later supply.

Method Summary

Modifier and Type	Method and Description
static <T> Reiterator<T,java.util.stream.Stream<T>>	aggregatingReiterator()
default java.util.Iterator<R>	iterator()
static <T> Reiterator<T,T>	latestReiterator()
default <U> Reiterator<T,U>	map(java.util.function.Function<R,U> map)
static <T> Reiterator<T,T>	queueReiterator()
default java.util.stream.Stream<R>	stream()

Methods inherited from interface java.util.function.Consumer

accept, andThen

Methods inherited from interface java.util.function.Supplier

get

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Method Detail

queueReiterator

static <T> Reiterator<T,T> queueReiterator()

latestReiterator

static <T> Reiterator<T,T> latestReiterator()

aggregatingReiterator

static <T> Reiterator<T,java.util.stream.Stream<T>> aggregatingReiterator()

map

default <U> Reiterator<T,U> map(java.util.function.Function<R,U> map)

iterator

default java.util.Iterator<R> iterator()

Specified by:

iterator in interface java.lang.Iterable<R>

stream

default java.util.stream.Stream<R> stream()

Returns:

A never-ending, blocking stream of events