You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 
 
 
 

49 lines
1.4 KiB

#ifndef SRC_JS_STREAM_H_
#define SRC_JS_STREAM_H_
#include "async-wrap.h"
#include "env.h"
#include "stream_base.h"
#include "v8.h"
namespace node {
class JSStream : public StreamBase, public AsyncWrap {
public:
static void Initialize(v8::Handle<v8::Object> target,
v8::Handle<v8::Value> unused,
v8::Handle<v8::Context> context);
~JSStream();
void* Cast() override;
bool IsAlive() override;
bool IsClosing() override;
int ReadStart() override;
int ReadStop() override;
int DoShutdown(ShutdownWrap* req_wrap) override;
int DoWrite(WriteWrap* w,
uv_buf_t* bufs,
size_t count,
uv_stream_t* send_handle) override;
protected:
JSStream(Environment* env, v8::Handle<v8::Object> obj, AsyncWrap* parent);
AsyncWrap* GetAsyncWrap() override;
static void New(const v8::FunctionCallbackInfo<v8::Value>& args);
static void DoAlloc(const v8::FunctionCallbackInfo<v8::Value>& args);
static void DoRead(const v8::FunctionCallbackInfo<v8::Value>& args);
static void DoAfterWrite(const v8::FunctionCallbackInfo<v8::Value>& args);
static void ReadBuffer(const v8::FunctionCallbackInfo<v8::Value>& args);
static void EmitEOF(const v8::FunctionCallbackInfo<v8::Value>& args);
template <class Wrap>
static void Finish(const v8::FunctionCallbackInfo<v8::Value>& args);
};
} // namespace node
#endif // SRC_JS_STREAM_H_