Reactive Buffer
no.ntnu.item.arctis.library

Import via SVN
Drop this link into the Arctis View

Description

Buffers elements between a producer and a consumer process.

This block is used in the following examples: BreakfastService, ReactiveBufferExample, RSS Speech Example

Origin

Author:Frank Alexander Kraemer
Provider:NTNU - Department of Telematics
Repository:http://svn.item.ntnu.no/arctis-lib (user= guest, login= guest)

Dependencies

Imported Building Blocks:
  • Buffer Control
Imported Libraries:none
Required Repositories:none


Block Instance Parameters
allowDuplicates:  boolean

When true, the buffer accepts duplicate entries, as in a list. . Default value is false.



Parameter Nodes
init

Initialize the block.

add:  Item

Adds objects to the internal buffer. If the consumer is not yet active, the first element will be passed via 'out'.

out:  Item

Objects arrive once they are added, but only if the consumer process is ready.

next

The consumer process uses this pin to signal its readiness after processing an object.

empty

Emits a control token whenever 'next' is invoked and the buffer has no more objects.

stop

stopped


External Behavior