MapInlet (SwimOS)

All Superinterfaces:

Inlet<I>

All Known Subinterfaces:

MapDownlink<K,V>, MapInletMapOutlet<KI,KO,VI,VO,I,O>, MapInletOutlet<K,V,I,O>, MapInoutlet<K,VI,VO,I,O>, MapLane<K,V>

All Known Implementing Classes:

AbstractMapInlet, AbstractMapInletMapOutlet, AbstractMapInletOutlet, AbstractMapInoutlet, FilterFieldsCombinator, FilterFieldsOperator, JoinMapLaneDownlink, MapDownlinkView, MapFieldValuesCombinator, MapFieldValuesOperator, MapLaneView, MapOutput, MemoizeMapCombinator, OutletMapInlet, ReduceFieldsCombinator, ReduceFieldsOperator, WatchFieldsCombinator, WatchFieldsOperator
```
public interface MapInlet<K,V,I>
extends Inlet<I>
```
Input connector into a Streamlet for a key-value map state.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`decohereOutputKey(K key, KeyEffect effect)`	Marks this `MapInlet` as needing an `effect` applied to a given `key`.
`void`	`recohereOutputKey(K key, int version)`	Updates the state of an individual `key` in this `MapInlet` to make it consistent with the target `version`.

Methods inherited from interface swim.streamlet.Inlet
bindInput, decohereOutput, disconnectInputs, disconnectOutputs, input, recohereOutput, unbindInput

- Method Detail
  - decohereOutputKey
```
void decohereOutputKey(K key,
                       KeyEffect effect)
```
    Marks this MapInlet as needing an effect applied to a given key. Decohering an individual key decoheres the entire state of the Inlet. But only the decoherent keys need to be updated in order to recohere the overall state of the Inlet.
  - recohereOutputKey
```
void recohereOutputKey(K key,
                       int version)
```
    Updates the state of an individual key in this MapInlet to make it consistent with the target version. The MapInlet only needs to update if the current version differs from the target version. To update the state of a key, the MapInlet first invokes MapOutlet.recohereInputKey(Object, int) on its input, if its input is a MapOutlet, or it invokes Outlet.recohereInput(int), if its input is not a MapOutlet. Then, if all decoherent keys have been recohered, the MapInlet invokes Streamlet.recohere(int) on its attached streamlet.