ports/com.group7.nodes

Package-level declarations

Types

class ArrivalNode<OutputT>(label: String, destination: PushOutputChannel<OutputT>, generator: Generator<OutputT>) : SourceNode, Source<OutputT> , HasProgressBars

Simulates connections to the outside world. Generates entities according to a provided Generator and sends them to its output channel at scheduled times. Acts as the entry point for traffic into the simulation.

BoundedQueueNode

class BoundedQueueNode<T>(label: String, source: PushInputChannel<T>, destination: PullOutputChannel<T>, val capacity: Int, policy: QueuePolicy<T> = FIFOQueuePolicy()) : ContainerNode<T> , Queue<T> , BoundedContainer<T>

A queue with a maximum capacity. Receives entities through a push channel and outputs through a pull channel.

ContainerNode

abstract class ContainerNode<T>(label: String, incoming: List<InputChannel<*, *>>, outgoing: List<OutputChannel<*, *>>) : Node, Container<T>

Base class for nodes that hold entities. Provides callbacks for entity entry and exit events, allowing tracking of occupancy and behavior throughout the simulation.

DeadEndNode

class DeadEndNode<InputT>(label: String, inputChannel: InputChannel<InputT, *>) : Node

Dead end node closes its input channel immediately, representing a queue node that is 'closed for business', and will crash the simulator if a vehicle is dispatched to this node.

DefaultSinkNode

sealed class DefaultSinkNode<InputT> : ContainerNode<InputT> , Sink<InputT>

Base class for sink nodes that terminate entities. Tracks results and occupancy of received entities.

DelayNode

class DelayNode<T>(label: String, source: PushInputChannel<T>, destination: PushOutputChannel<T>, delayProvider: DelayProvider) : ContainerNode<T> , Delay<T> , HasProgressBars

Introduces a time delay to entities passing through. Receives entities and delays them before sending them to the destination, with the delay determined by the delayProvider.

LossSinkNode

class LossSinkNode<InputT>(label: String, source: PushInputChannel<InputT>) : DefaultSinkNode<InputT> , LossSink<InputT>

A sink that represents entities lost or discarded from the system.

MatchNode

class MatchNode<MainInputT, SideInputT, OutputT, ChannelT : ChannelType<ChannelT>>(label: String, mainSource: InputChannel<MainInputT, ChannelT>, sideSource: PullInputChannel<SideInputT>, destination: OutputChannel<OutputT, ChannelT>, combiner: (MainInputT, SideInputT) -> OutputT) : PassthroughNode<MainInputT, OutputT, ChannelT> , Match<MainInputT, SideInputT, OutputT>

Combines entities from a main input and a side input into a single output. Each main entity is matched with a corresponding side entity using the combiner function. The node remains ready only when the side input is ready.

PassthroughNode

abstract class PassthroughNode<InputT, OutputT, ChannelT : ChannelType<ChannelT>>(label: String, source: InputChannel<InputT, ChannelT>, destination: OutputChannel<OutputT, ChannelT>, sources: List<InputChannel<*, *>>, destinations: List<OutputChannel<*, *>>) : Node

Base class for nodes that process entities one-to-one from input to output while managing readiness. Subclasses implement process to transform entities and isReady to control flow. Automatically adapts to push/pull channel types.

PumpNode

class PumpNode<T>(label: String, source: PullInputChannel<T>, destination: PushOutputChannel<T>) : Node

Converts from pull-based to push-based flow. Actively pulls entities from the source and pushes them to the destination when both are ready.

QueueNode

class QueueNode<T>(label: String, source: PushInputChannel<T>, destination: PullOutputChannel<T>, policy: QueuePolicy<T> = FIFOQueuePolicy()) : ContainerNode<T> , Queue<T>

A queue that receives entities through a push channel and outputs them through a pull channel. Entities are stored and ordered according to the provided QueuePolicy (defaults to FIFO). The queue remains open to receive entities and signals readiness when it contains items.

ServiceNode

class ServiceNode<T>(label: String, source: PushInputChannel<T>, destination: PushOutputChannel<T>, delayProvider: DelayProvider, numServers: Int) : ContainerNode<T> , Service<T> , HasProgressBars

Processes entities through parallel servers, each introducing a delay. When all servers are busy, the input channel closes to prevent additional arrivals. Reopens when a server becomes available.

SinkNode

class SinkNode<InputT>(label: String, source: PushInputChannel<InputT>) : DefaultSinkNode<InputT> , OutputSink<InputT>

A sink that represents the output destination for successfully processed entities.

SplitNode

class SplitNode<InputT, MainOutputT, SideOutputT, ChannelT : ChannelType<ChannelT>>(label: String, source: InputChannel<InputT, ChannelT>, mainDestination: OutputChannel<MainOutputT, ChannelT>, sideDestination: PushOutputChannel<SideOutputT>, splitter: (InputT) -> Pair<MainOutputT, SideOutputT>) : PassthroughNode<InputT, MainOutputT, ChannelT> , Split<InputT, MainOutputT, SideOutputT>

Splits entities into two outputs: a main output and a side output. Each incoming entity is processed by the splitter function to produce both outputs. The node remains ready only when the side destination is open.