io.github.privacystreams.core

Class PStreamTransformation

java.lang.Object

io.github.privacystreams.core.Function<Tin,Tout>

io.github.privacystreams.core.EventDrivenFunction<PStream,PStream>

io.github.privacystreams.core.PStreamTransformation

public abstract class PStreamTransformation
extends EventDrivenFunction<PStream,PStream>

Transform a stream to a stream

Field Summary

Fields inherited from class io.github.privacystreams.core.EventDrivenFunction

input, output

Fields inherited from class io.github.privacystreams.core.Function

isCancelled

Constructor Summary

Constructors

Constructor and Description
PStreamTransformation()

Method Summary

Modifier and Type	Method and Description
protected void	finish()
protected void	init()
protected void	onCancel(UQI uqi) Callback when this function is cancelled
void	onEvent(Item item)
protected abstract void	onInput(Item item)
protected void	output(Item item)

Methods inherited from class io.github.privacystreams.core.EventDrivenFunction

apply, getContext, getUQI

Methods inherited from class io.github.privacystreams.core.Function

addParameters, addRequiredPermissions, cancel, compound, getHead, getParameters, getRequiredPermissions, getTail, raiseException, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

PStreamTransformation

public PStreamTransformation()

Method Detail

onInput

protected abstract void onInput(Item item)

output

protected final void output(Item item)

onEvent

@Subscribe
public final void onEvent(Item item)

init

protected void init()

Specified by:

init in class EventDrivenFunction<PStream,PStream>

finish

protected final void finish()

onCancel

protected final void onCancel(UQI uqi)

Description copied from class: Function

Callback when this function is cancelled

Overrides:

onCancel in class Function<PStream,PStream>

Parameters:

uqi - the instance of UQI