0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-09-28 19:58:53 +02:00

modules: Add stream interface object.

This commit is contained in:
Jason Volk 2016-11-13 16:41:31 -08:00
parent 63a6a82ea2
commit eef5b78112
2 changed files with 79 additions and 4 deletions

View file

@ -53,8 +53,7 @@ require_la_SOURCES = require.cc
events_la_SOURCES = events.cc
assert_la_SOURCES = assert.cc
console_la_SOURCES = console.cc
m_host_la_SOURCES = m_host.cc
m_get_la_SOURCES = m_get.cc
stream_la_SOURCES = stream.cc
#m_ban_la_SOURCES = m_ban.cc
#m_die_la_SOURCES = m_die.cc
#m_error_la_SOURCES = m_error.cc
@ -145,8 +144,7 @@ require.la \
assert.la \
events.la \
console.la \
m_host.la \
m_get.la
stream.la
# m_modules.la
# m_ban.la \

77
modules/stream.cc Normal file
View file

@ -0,0 +1,77 @@
/*
* Copyright (C) 2016 Charybdis Development Team
* Copyright (C) 2016 Jason Volk <jason@zemos.net>
*
* Permission to use, copy, modify, and/or distribute this software for any
* purpose with or without fee is hereby granted, provided that the above
* copyright notice and this permission notice is present in all copies.
*
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT,
* INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
* STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
* IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGE.
*/
#include <ircd/js/js.h>
namespace ircd {
namespace js {
struct stream
:trap
{
struct read;
void on_new(object::handle, object &, const args &) override;
stream()
:trap{"stream"}
{
parent_prototype = &trap::find("events");
}
}
static stream;
struct stream::read
:trap::function
{
value on_call(object::handle, value::handle, const args &) override;
using trap::function::function;
}
static read{stream, "read"};
void
stream::on_new(object::handle callee,
object &that,
const args &args)
{
}
value
stream::read::on_call(object::handle callee,
value::handle _that,
const args &args)
{
object that(_that);
printf("read\n");
return {};
}
} // namespace js
} // namespace ircd
using namespace ircd::js;
using namespace ircd;
mapi::header IRCD_MODULE
{
"Abstract interface for working with streaming data"
};