Module swim.streamlet

Package swim.streamlet.combinator

Class WatchFieldsCombinator<K,V,O>

java.lang.Object

swim.streamlet.AbstractMapInlet<K,V,O>

swim.streamlet.combinator.WatchFieldsOperator<K,V,O>

swim.streamlet.combinator.WatchFieldsCombinator<K,V,O>

All Implemented Interfaces:

Inlet<O>, MapInlet<K,V,O>

public class WatchFieldsCombinator<K,V,O>
extends WatchFieldsOperator<K,V,O>

Field Summary

Fields

Modifier and Type	Field	Description
protected WatchFieldsFunction<? super K,? super V>	func

Fields inherited from class swim.streamlet.AbstractMapInlet

effects, input, version

Constructor Summary

Constructors

Constructor	Description
WatchFieldsCombinator(WatchFieldsFunction<? super K,? super V> func)

Method Summary

Modifier and Type	Method	Description
void	evaluate(K key, V value)

Methods inherited from class swim.streamlet.combinator.WatchFieldsOperator

onRecohereOutputKey

Methods inherited from class swim.streamlet.AbstractMapInlet

bindInput, bindInput, decohereOutput, decohereOutputKey, didDecohereOutput, didDecohereOutputKey, didRecohereOutput, didRecohereOutputKey, disconnectInputs, disconnectOutputs, input, onDecohereOutput, onDecohereOutputKey, onRecohereOutput, recohereOutput, recohereOutputKey, unbindInput, willDecohereOutput, willDecohereOutputKey, willRecohereOutput, willRecohereOutputKey

Methods inherited from class java.lang.Object

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

Field Detail

func

protected final WatchFieldsFunction<? super K,? super V> func

Constructor Detail

WatchFieldsCombinator

public WatchFieldsCombinator(WatchFieldsFunction<? super K,? super V> func)

Method Detail

evaluate

public void evaluate(K key,
                     V value)

Specified by:

evaluate in class WatchFieldsOperator<K,V,O>