1 files changed, 79 insertions, 0 deletions
diff --git a/test/multiplexing.lua b/test/multiplexing.lua
new file mode 100755
index 0000000..8265e4c
--- /dev/null
+++ b/test/multiplexing.lua
@@ -0,0 +1,79 @@
+#!bin/lem
+--
+-- This file is part of LEM, a Lua Event Machine.
+-- Copyright 2011-2012 Emil Renner Berthing
+--
+-- LEM is free software: you can redistribute it and/or
+-- modify it under the terms of the GNU General Public License as
+-- published by the Free Software Foundation, either version 3 of
+-- the License, or (at your option) any later version.
+--
+-- LEM is distributed in the hope that it will be useful,
+-- but WITHOUT ANY WARRANTY; without even the implied warranty of
+-- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+-- GNU General Public License for more details.
+--
+-- You should have received a copy of the GNU General Public License
+-- along with LEM.  If not, see <http://www.gnu.org/licenses/>.
+--
+
+local utils   = require 'lem.utils'
+local streams = require 'lem.streams'
+local queue   = require 'lem.streams.queue'
+
+local exit   = false
+local ticker = utils.sleeper()
+local stdout = queue.wrap(streams.stdout)
+
+do
+	local format = string.format
+	function queue.QOStream:printf(...)
+		return self:write(format(...))
+	end
+end
+
+-- this function just reads lines from a
+-- stream and prints them to stdout
+local function poll(stream, name)
+	repeat
+		local line, err = stream:read('*l')
+		if not line then
+			stdout:printf('%s: %s\n', name, err)
+			break
+		end
+
+		stdout:printf('%s: %s\n', name, line)
+	until line == 'quit'
+
+	exit = true
+	ticker:wakeup()
+end
+
+-- type 'mkfifo pipe' to create a named pipe for this script
+-- and do 'cat > pipe' (in another terminal) to write to it
+local pipe = assert(streams.open(arg[1] or 'pipe', 'r'))
+
+-- spawn coroutines to read from stdin and the pipe
+utils.spawn(poll, streams.stdin, 'stdin')
+utils.spawn(poll, pipe, 'pipe')
+
+do
+	--local out = streams.stderr
+	local out = stdout
+	local sound
+
+	repeat
+		if sound == 'tick\n' then
+			sound = 'tock\n'
+		else
+			sound = 'tick\n'
+		end
+		out:write(sound)
+		ticker:sleep(1.0)
+	until exit
+end
+
+streams.stdin:close()
+pipe:close()
+
+-- vim: syntax=lua ts=2 sw=2 noet: