To create a back-pressure mechanism for messages that do not associated with a limited resource pool based on output buffers:
Whenever a message is sent, a reference counted token from the output port is sent along with that message. The reference counted token stays with the message until the message is consumed by the downstream, then the token is returned to the upstream output port. Work will not be called on a block until it has at least one token available.
guruofquality
commented
10 years ago
To create a back-pressure mechanism for messages that do not associated with a limited resource pool based on output buffers:
Whenever a message is sent, a reference counted token from the output port is sent along with that message. The reference counted token stays with the message until the message is consumed by the downstream, then the token is returned to the upstream output port. Work will not be called on a block until it has at least one token available.