add more libraries

1 files changed, 50 insertions, 0 deletions

diff --git a/lem/streams.lua b/lem/streams.lua
new file mode 100644
index 0000000..f4f9d4f
--- /dev/null
+++ b/lem/streams.lua
@@ -0,0 +1,50 @@
+--
+-- 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 M = require 'lem.streams.core'
+
+do
+	local type = type
+	local parsers = M.parsers
+	local parser_available = parsers.available
+	parsers.available = nil
+	local parser_target = parsers.target
+	parsers.target = nil
+
+	function M.reader(readp)
+		return function(self, fmt, ...)
+			if fmt == nil then
+				return readp(self, parser_available)
+			end
+			if type(fmt) == 'number' then
+				return readp(self, parser_target, fmt)
+			end
+			local parser = parsers[fmt]
+			if parser == nil then
+				error('invalid format', 2)
+			end
+			return readp(self, parser, ...)
+		end
+	end
+
+	M.IStream.read = M.reader(M.IStream.readp)
+end
+
+return M
+
+-- vim: ts=2 sw=2 noet: