diff options
Diffstat (limited to 'lem/streams.lua')
| -rw-r--r-- | lem/streams.lua | 50 |
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: |