Reactive Buffer 2
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. In this variant, the consumer has to notify its readiness before items are offered to it.

This block is used in the following example: ReactiveBuffer2Example

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 2
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
add:  Item

Adds objects to the internal buffer.

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.

empty

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

stop

stopped


External Behavior