manan-data 0.0.0

inventyv tikv datalayer
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

'use strict';
function controlFlow(channel) {
	let errored = false;
	let deliverImmediately = true;

	const backlog = [];
	const deliverNext = error => {
		if (error !== null) {
			errored = true;
		}

		if (errored || !channel.connected) {
			backlog.length = 0; // Free memory.
			return; // We can't send.
		}

		let ok = true;
		while (ok && backlog.length > 0) { // Stop sending after backpressure.
			ok = channel.send(backlog.shift(), deliverNext);
		}

		// Re-enable immediate delivery if there is no backpressure and the backlog
		// has been cleared.
		deliverImmediately = ok && backlog.length === 0;
	};

	return message => {
		if (errored || !channel.connected) {
			return;
		}

		if (deliverImmediately) {
			deliverImmediately = channel.send(message, deliverNext);
		} else {
			backlog.push(message);
		}
	};
}

exports.controlFlow = controlFlow;