Module swim.streamlet

Package swim.streamlet.combinator

Class MemoizeMapCombinator<K,V,IO>

java.lang.Object

swim.streamlet.AbstractMapInoutlet<K,V,V,IO,IO>

swim.streamlet.combinator.MemoizeMapCombinator<K,V,IO>

All Implemented Interfaces:

Inlet<IO>, Inoutlet<IO,IO>, MapInlet<K,V,IO>, MapInoutlet<K,V,V,IO,IO>, MapOutlet<K,V,IO>, Outlet<IO>

public class MemoizeMapCombinator<K,V,IO>
extends AbstractMapInoutlet<K,V,V,IO,IO>

Field Summary

Fields

Modifier and Type	Field	Description
protected HashTrieMap<K,V>	cache
protected IO	state

Fields inherited from class swim.streamlet.AbstractMapInoutlet

effects, input, outlets, outputs, version

Constructor Summary

Constructors

Constructor	Description
MemoizeMapCombinator()

Method Summary

Modifier and Type	Method	Description
boolean	containsKey(K key)	Returns true if the current state of this MapOutlet contains the given key; otherwise returns false.
IO	get()	Returns the current state of this Outlet.
V	get(K key)	Returns the value assocaited with the given key in the current state of this MapOutlet, if defined; otherwise returns null.
Iterator<K>	keyIterator()	Returns an Iterator over the keys in the current state of this MapOutlet.
MapOutlet<K,V,IO>	memoize()
protected void	onRecohere(int version)
protected void	onRecohereKey(K key, KeyEffect effect, int version)

Methods inherited from class swim.streamlet.AbstractMapInoutlet

bindInput, bindInput, bindOutput, decohere, decohereInput, decohereInputKey, decohereKey, decohereOutput, decohereOutputKey, didDecohere, didDecohereKey, didRecohere, didRecohereKey, disconnectInputs, disconnectOutputs, input, onDecohere, onDecohereKey, outlet, outputIterator, recohere, recohereInput, recohereInputKey, recohereKey, recohereOutput, recohereOutputKey, unbindInput, unbindOutput, unbindOutputs, willDecohere, willDecohereKey, willRecohere, willRecohereKey

Methods inherited from class java.lang.Object

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

Methods inherited from interface swim.streamlet.MapOutlet

filter, map, reduce, watch

Methods inherited from interface swim.streamlet.Outlet

map, watch

Field Details

state

protected IO state

cache

protected HashTrieMap<K,V> cache

Constructor Details

MemoizeMapCombinator

public MemoizeMapCombinator()

Method Details

containsKey

public boolean containsKey(K key)

Description copied from interface: MapOutlet

Returns true if the current state of this MapOutlet contains the given key; otherwise returns false.

Specified by:

containsKey in interface MapOutlet<K,V,IO>

Specified by:

containsKey in class AbstractMapInoutlet<K,V,V,IO,IO>

get

public V get(K key)

Description copied from interface: MapOutlet

Returns the value assocaited with the given key in the current state of this MapOutlet, if defined; otherwise returns null.

Specified by:

get in interface MapOutlet<K,V,IO>

Specified by:

get in class AbstractMapInoutlet<K,V,V,IO,IO>

get

public IO get()

Description copied from interface: Outlet

Returns the current state of this Outlet.

Specified by:

get in interface Outlet<K>

Specified by:

get in class AbstractMapInoutlet<K,V,V,IO,IO>

keyIterator

public Iterator<K> keyIterator()

Description copied from interface: MapOutlet

Returns an Iterator over the keys in the current state of this MapOutlet.

Specified by:

keyIterator in interface MapOutlet<K,V,IO>

Specified by:

keyIterator in class AbstractMapInoutlet<K,V,V,IO,IO>

onRecohereKey

protected void onRecohereKey(K key,
 KeyEffect effect,
 int version)

Overrides:

onRecohereKey in class AbstractMapInoutlet<K,V,V,IO,IO>

onRecohere

protected void onRecohere(int version)

Overrides:

onRecohere in class AbstractMapInoutlet<K,V,V,IO,IO>

memoize

public MapOutlet<K,V,IO> memoize()