Abstract StreamWrap from TCPWrap

1 files changed, 35 insertions, 0 deletions

diff --git a/src/req_wrap.h b/src/req_wrap.h
new file mode 100644
index 0000000000..cc60547013
--- /dev/null
+++ b/src/req_wrap.h
@@ -0,0 +1,35 @@
+#ifndef REQ_WRAP_H_
+#define REQ_WRAP_H_
+
+namespace node {
+
+template <typename T>
+class ReqWrap {
+ public:
+  ReqWrap() {
+    v8::HandleScope scope;
+    object_ = v8::Persistent<v8::Object>::New(v8::Object::New());
+  }
+
+  ~ReqWrap() {
+    // Assert that someone has called Dispatched()
+    assert(req_.data == this);
+    assert(!object_.IsEmpty());
+    object_.Dispose();
+    object_.Clear();
+  }
+
+  // Call this after the req has been dispatched.
+  void Dispatched() {
+    req_.data = this;
+  }
+
+  v8::Persistent<v8::Object> object_;
+  T req_;
+};
+
+
+}  // namespace node
+
+
+#endif  // REQ_WRAP_H_