io.github.privacystreams.core.transformations.map

Class Mappers

java.lang.Object

io.github.privacystreams.core.transformations.map.Mappers

@PSOperatorWrapper
public class Mappers
extends java.lang.Object

A helper class to access reorder functions

Constructor Summary

Constructors

Constructor and Description
Mappers()

Method Summary

Modifier and Type	Method and Description
static PStreamTransformation	inFixedInterval(long fixedInterval) Make the items be sent in a fixed interval.
static PStreamTransformation	mapEachItem(Function<Item,Item> perItemMapper) Transform a multi-item stream by mapping each items with a item-to-item mapper.

Methods inherited from class java.lang.Object

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

Constructor Detail

Mappers

public Mappers()

Method Detail

mapEachItem

public static PStreamTransformation mapEachItem(Function<Item,Item> perItemMapper)

Transform a multi-item stream by mapping each items with a item-to-item mapper.

Parameters:

perItemMapper - the mapper function to map each item in the stream.

Returns:

the stream mapper function.

inFixedInterval

public static PStreamTransformation inFixedInterval(long fixedInterval)

Make the items be sent in a fixed interval.

Parameters:

fixedInterval - the fixed interval in milliseconds.

Returns:

the stream mapper function.