Comparison

net.server_select, net.server_event: Add server.link() to link 2 connections with an intermediate buffer of the specified size

comparison

equal deleted inserted replaced

-:d1f864ed44c0
+:48871a549b4c
 	end
 	signal_events[signal_num] = base:addevent(signal_num, EV_SIGNAL, _handler);
 	return signal_events[signal_num];
 end
+local function link(sender, receiver, buffersize)
+	sender:set_mode(buffersize);
+	local sender_locked;
+	function receiver:ondrain()
+		if sender_locked then
+			sender:resume();
+			sender_locked = nil;
+		end
+	end
+	function sender:onincoming(data)
+		receiver:write(data);
+		if receiver.writebufferlen >= buffersize then
+			sender_locked = true;
+			sender:pause();
+		end
+	end
+end
 return {
 	cfg = cfg,
 	base = base,
 	loop = loop,
+	link = link,
 	event = event,
 	event_base = base,
 	addevent = newevent,
 	addserver = addserver,
 	addclient = addclient,