Module swim.api

Package swim.api.downlink

Class DownlinkStreamlet

java.lang.Object

swim.structure.Item

swim.structure.Value

swim.structure.Record

swim.dataflow.RecordStreamlet<I,O>

swim.dataflow.AbstractRecordStreamlet<Value,Value>

swim.api.downlink.DownlinkStreamlet

All Implemented Interfaces:

Comparable<Item>, Iterable<Item>, Collection<Item>, List<Item>, Debug, Display, GenericStreamlet<Value,Value>, Streamlet<Value,Value>, StreamletScope<Value>, Builder<Item,Record>, PairBuilder<Value,Value,Record>

public class DownlinkStreamlet
extends AbstractRecordStreamlet<Value,Value>

Field Summary

Fields

Modifier and Type	Field	Description
Inoutlet<Value,Value>	body
protected Downlink	downlink
protected DownlinkRecord	downlinkRecord
Inoutlet<Value,Value>	hostUri
protected Value	inputBody
protected String	inputHostUri
protected String	inputLaneUri
protected String	inputNodeUri
protected float	inputPrio
protected float	inputRate
protected String	inputType
Inoutlet<Value,Value>	laneUri
Inoutlet<Value,Value>	nodeUri
Inoutlet<Value,Value>	prio
Inoutlet<Value,Value>	rate
Outlet<Value>	state
Inoutlet<Value,Value>	type
protected WarpRef	warp

Fields inherited from class swim.dataflow.AbstractRecordStreamlet

context, scope, version

Constructor Summary

Constructors

Constructor	Description
DownlinkStreamlet(WarpRef warp)
DownlinkStreamlet(WarpRef warp, StreamletScope<? extends Value> scope)

Method Summary

Modifier and Type	Method	Description
Value	getOutput(Outlet<? super Value> outlet)
protected void	onRecohere(int version)
static Reifier	reifier(WarpRef warp)

Methods inherited from class swim.dataflow.AbstractRecordStreamlet

add, add, bindInput, castInput, castInput, castInput, castInput, clear, coerceInput, coerceInput, coerceInput, coerceInput, compileInlets, containsKey, containsKey, decohere, didDecohere, didDecohereInlet, didDecohereOutlet, didRecohere, didRecohereInlet, didRecohereOutlet, disconnectInputs, disconnectOutputs, get, get, get, getAttr, getAttr, getField, getField, getInput, getInput, getInput, getInput, getItem, getOutput, getSlot, getSlot, inlet, inlet, inoutlet, isEmpty, onDecohere, onDecohereOutlets, onRecohereInlets, onRecohereOutlets, outlet, outlet, put, put, putAttr, putAttr, putSlot, putSlot, recohere, remove, removeKey, removeKey, setItem, setStreamletContext, setStreamletScope, size, streamletContext, streamletScope, unbindInput, willDecohere, willDecohereInlet, willDecohereOutlet, willRecohere, willRecohereInlet, willRecohereOutlet

Methods inherited from class swim.dataflow.RecordStreamlet

compile, compileInlet, isConstant

Methods inherited from class swim.structure.Record

add, add, add, add, add, add, add, add, add, add, add, add, add, addAll, addAll, alias, appended, appended, asMutable, attr, attr, attr, attr, attr, attr, attr, attr, attr, attr, attr, attr, attr, attr, attr, attr, bind, body, branch, commit, compareTo, compareTo, concat, contains, contains, containsAll, containsValue, create, create, debug, empty, entrySet, equals, evaluate, fieldCount, fieldIterator, fieldSet, flattened, hashCode, head, header, headers, indexOf, isAliased, isArray, isDefinite, isMutable, isObject, item, item, item, item, item, item, item, iterator, keyIterator, keySet, lastIndexOf, length, listIterator, listIterator, of, of, of, prepended, prepended, put, put, put, put, put, put, put, put, put, put, put, put, putAll, putAttr, putAttr, putAttr, putAttr, putAttr, putAttr, putAttr, putAttr, putAttr, putAttr, putAttr, putAttr, putSlot, putSlot, putSlot, putSlot, putSlot, putSlot, putSlot, putSlot, putSlot, putSlot, putSlot, putSlot, remove, removeAll, removed, removed, retainAll, set, setItem, setItem, setItem, setItem, setItem, setItem, slot, slot, slot, slot, slot, slot, slot, slot, slot, slot, slot, slot, slot, slot, slot, slot, stringValue, stringValue, subList, substitute, tag, tail, target, toArray, toArray, typeOrder, unflattened, updated, updated, updatedAttr, updatedAttr, updatedSlot, updatedSlot, valueCount, valueIterator, values

Methods inherited from class swim.structure.Value

absent, and, and, bitwiseAnd, bitwiseAnd, bitwiseNot, bitwiseOr, bitwiseOr, bitwiseXor, bitwiseXor, booleanValue, booleanValue, builder, byteValue, byteValue, charValue, charValue, conditional, conditional, divide, divide, doubleValue, doubleValue, eq, eq, extant, floatValue, floatValue, fromObject, ge, ge, gt, gt, integerValue, integerValue, intValue, intValue, inverse, isDefined, isDistinct, key, keyEquals, lambda, le, le, longValue, longValue, lt, lt, minus, minus, modulo, modulo, ne, ne, negative, not, numberValue, numberValue, or, or, plus, plus, positive, shortValue, shortValue, times, times, toValue

Methods inherited from class swim.structure.Item

appended, appended, appended, appended, appended, appended, cast, cast, coerce, coerce, display, evaluate, filter, filter, globalScope, invoke, max, min, precedence, prepended, prepended, prepended, prepended, prepended, prepended, substitute, toString, updated, updated, updated, updated, updated, updated, updated, updated, updated, updated, updated, updated, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Collection

parallelStream, removeIf, stream, toArray

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface java.util.List

replaceAll, sort, spliterator

Field Detail

hostUri

@Inout
public final Inoutlet<Value,Value> hostUri

nodeUri

@Inout
public final Inoutlet<Value,Value> nodeUri

laneUri

@Inout
public final Inoutlet<Value,Value> laneUri

prio

@Inout
public final Inoutlet<Value,Value> prio

rate

@Inout
public final Inoutlet<Value,Value> rate

body

@Inout
public final Inoutlet<Value,Value> body

type

@Inout
public final Inoutlet<Value,Value> type

warp

protected final WarpRef warp

state

@Out
public Outlet<Value> state

downlink

protected Downlink downlink

downlinkRecord

protected DownlinkRecord downlinkRecord

inputHostUri

protected String inputHostUri

inputNodeUri

protected String inputNodeUri

inputLaneUri

protected String inputLaneUri

inputPrio

protected float inputPrio

inputRate

protected float inputRate

inputBody

protected Value inputBody

inputType

protected String inputType

Constructor Detail

DownlinkStreamlet

public DownlinkStreamlet(WarpRef warp,
                         StreamletScope<? extends Value> scope)

DownlinkStreamlet

public DownlinkStreamlet(WarpRef warp)

Method Detail

getOutput

public Value getOutput(Outlet<? super Value> outlet)

Specified by:

getOutput in interface GenericStreamlet<Value,Value>

Overrides:

getOutput in class AbstractRecordStreamlet<Value,Value>

onRecohere

protected void onRecohere(int version)

Overrides:

onRecohere in class AbstractRecordStreamlet<Value,Value>

reifier

public static Reifier reifier(WarpRef warp)