com.groupon.lex.metrics.history.xdr.support.reader

Interface SegmentReader<T>

All Known Implementing Classes:

FileChannelSegmentReader

public interface SegmentReader<T>

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	SegmentReader.Factory<BaseType>

Method Summary

Modifier and Type	Method and Description
default SegmentReader<T>	cache()
default SegmentReader<T>	cache(T current)
default <U,R> SegmentReader<R>	combine(SegmentReader<U> other, BiFunction<? super T,? super U,? extends R> fn)
T	decode()
default T	decodeOrThrow()
default <Exc extends Exception> T	decodeOrThrow(Function<Exception,Exc> exc)
default SegmentReader<Optional<T>>	filter(Predicate<? super T> pred)
default <U> SegmentReader<U>	flatMap(Function<? super T,? extends SegmentReader<? extends U>> fn)
default <U> SegmentReader<U>	map(Function<? super T,? extends U> fn)
static <T> SegmentReader<T>	of(T v)
static <T> SegmentReader<T>	ofSupplier(Supplier<T> v)
default SegmentReader<T>	peek(Consumer<? super T> fn)
default SegmentReader<T>	share()

Method Detail

decode

T decode()
  throws IOException,
         org.acplt.oncrpc.OncRpcException

Throws:

IOException

org.acplt.oncrpc.OncRpcException

decodeOrThrow

default <Exc extends Exception> T decodeOrThrow(Function<Exception,Exc> exc)
                                         throws Exc extends Exception

Throws:

Exc extends Exception

decodeOrThrow

default T decodeOrThrow()
                 throws DecodingException

Throws:

DecodingException

of

static <T> SegmentReader<T> of(T v)

ofSupplier

static <T> SegmentReader<T> ofSupplier(Supplier<T> v)

map

default <U> SegmentReader<U> map(Function<? super T,? extends U> fn)

flatMap

default <U> SegmentReader<U> flatMap(Function<? super T,? extends SegmentReader<? extends U>> fn)

combine

default <U,R> SegmentReader<R> combine(SegmentReader<U> other,
                                       BiFunction<? super T,? super U,? extends R> fn)

peek

default SegmentReader<T> peek(Consumer<? super T> fn)

share

default SegmentReader<T> share()

cache

default SegmentReader<T> cache()

cache

default SegmentReader<T> cache(T current)

filter

default SegmentReader<Optional<T>> filter(Predicate<? super T> pred)