io.github.privacystreams.core.actions.callback

Class Callbacks

java.lang.Object

io.github.privacystreams.core.actions.callback.Callbacks

@PSOperatorWrapper
public class Callbacks
extends java.lang.Object

A helper class to access callback-related functions

Constructor Summary

Constructors

Constructor and Description
Callbacks()

Method Summary

Modifier and Type	Method and Description
static PStreamAction	forEach(Function<Item,java.lang.Void> itemCallback) Callback with each item in the stream.
static <TValue> PStreamAction	forEachField(java.lang.String fieldToSelect, Function<TValue,java.lang.Void> fieldValueCallback) Callback with the field value for each item in the stream.
static <TValue> PStreamAction	ifFieldPresent(java.lang.String fieldToSelect, Function<TValue,java.lang.Void> fieldValueCallback) Callback with the first present field value in the stream.
static PStreamAction	ifPresent(Function<Item,java.lang.Void> itemCallback) Callback with the first item in the stream.
static PStreamAction	onChange(Function<Item,java.lang.Void> itemCallback) Callback with the changed items in the stream.
static <TValue> PStreamAction	onFieldChange(java.lang.String fieldToSelect, Function<TValue,java.lang.Void> fieldValueCallback) Callback with the changed field value of a given field in the stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

Callbacks

public Callbacks()

Method Detail

forEach

public static PStreamAction forEach(Function<Item,java.lang.Void> itemCallback)

Callback with each item in the stream. The callback will be invoked with each item as a parameter.

Parameters:

itemCallback - the callback to be invoked for each item

Returns:

the function

forEachField

public static <TValue> PStreamAction forEachField(java.lang.String fieldToSelect,
                                                  Function<TValue,java.lang.Void> fieldValueCallback)

Callback with the field value for each item in the stream. The callback will be invoked with the field value for each item.

Type Parameters:

TValue - the type of field value

Parameters:

fieldToSelect - the field to select

fieldValueCallback - the callback function to be invoked for each field value

Returns:

the function

ifPresent

public static PStreamAction ifPresent(Function<Item,java.lang.Void> itemCallback)

Callback with the first item in the stream. If there is no present item, the callback will not be invoked. The callback will be invoked with the present item as a parameter.

Parameters:

itemCallback - the callback to be invoked with the first item.

Returns:

the function

ifFieldPresent

public static <TValue> PStreamAction ifFieldPresent(java.lang.String fieldToSelect,
                                                    Function<TValue,java.lang.Void> fieldValueCallback)

Callback with the first present field value in the stream. If there is no item with a present field value, the callback will not be invoked. The callback will be invoked with the present field value.

Type Parameters:

TValue - the type of field value

Parameters:

fieldToSelect - the field to select

fieldValueCallback - the callback function to be invoked with the first field value

Returns:

the function

onChange

public static PStreamAction onChange(Function<Item,java.lang.Void> itemCallback)

Callback with the changed items in the stream. A changed item is the item that is different from the former item. The callback will be invoked with the item as a parameter.

Parameters:

itemCallback - the callback to be invoked with the changed item.

Returns:

the function

onFieldChange

public static <TValue> PStreamAction onFieldChange(java.lang.String fieldToSelect,
                                                   Function<TValue,java.lang.Void> fieldValueCallback)

Callback with the changed field value of a given field in the stream. A changed field value is the field value that is different from the former field value. null values are ignored. The callback will be invoked with the field value as a parameter.

Type Parameters:

TValue - the type of field value

Parameters:

fieldToSelect - the field to select

fieldValueCallback - the callback function to be invoked with the changed field value.

Returns:

the function