The current implementation passes along a reference of ComponentDefinition across multiple functions just so that a ChannelStrategy can use it for kompacts tell_serialised function.
Refactor ChannelStrategy to return an iterator of (Channel, ArconMessage) that can be dispatched from the Node/SourceNode itself. This way we also can handle potential buffer errors easier too.
The above change also relates to operators as we also pass a ComponentDefinition reference into the OperatorContext.
Rather than outputting events through ctx.output(event), make handle_element/handle_timeout return an element iterator.
The current implementation passes along a reference of
ComponentDefinitionacross multiple functions just so that aChannelStrategycan use it for kompactstell_serialisedfunction.Refactor
ChannelStrategyto return an iterator of (Channel, ArconMessage) that can be dispatched from the Node/SourceNode itself. This way we also can handle potential buffer errors easier too.The above change also relates to operators as we also pass a
ComponentDefinitionreference into theOperatorContext.Rather than outputting events through
ctx.output(event), makehandle_element/handle_timeoutreturn an element iterator.This change is also required for it to be possible to create an operator chain (#246).