quic: Move DataQueueFeeder parts to header for non-windows build

Author: martenrichter

src/quic/streams.cc

@@ -1338,32 +1338,6 @@ DataQueueFeeder::DataQueueFeeder(Environment* env, Local<Object> object)
   MakeWeak();
 }
 
-void DataQueueFeeder::tryWakePulls() {
-  if (!readFinish_.IsEmpty()) {
-    Local<Promise::Resolver> resolver = readFinish_.Get(env()->isolate());
-    // I do not think, that this can error...
-    (void)resolver->Resolve(env()->context(), v8::True(env()->isolate()));
-    readFinish_.Reset();
-  }
-}
-
-void DataQueueFeeder::DrainAndClose() {
-  if (done) return;
-  done = true;
-  // do not do this several time, and note,
-  // it may be called several times.
-  while (!pendingPulls_.empty()) {
-    auto& pending = pendingPulls_.front();
-    auto pop = OnScopeLeave([this] { pendingPulls_.pop_front(); });
-    pending.next(bob::STATUS_EOS, nullptr, 0, [](uint64_t) {});
-  }
-  if (!readFinish_.IsEmpty()) {
-    Local<Promise::Resolver> resolver = readFinish_.Get(env()->isolate());
-    (void)resolver->Resolve(env()->context(), v8::False(env()->isolate()));
-    readFinish_.Reset();
-  }
-}
-
 JS_METHOD_IMPL(DataQueueFeeder::New) {
   DCHECK(args.IsConstructCall());
   auto env = Environment::GetCurrent(args);

src/quic/streams.h

@@ -436,6 +436,32 @@ class DataQueueFeeder final : public AsyncWrap {
   bool done = false;
 };
 
+void DataQueueFeeder::tryWakePulls() {
+  if (!readFinish_.IsEmpty()) {
+    Local<Promise::Resolver> resolver = readFinish_.Get(env()->isolate());
+    // I do not think, that this can error...
+    (void)resolver->Resolve(env()->context(), v8::True(env()->isolate()));
+    readFinish_.Reset();
+  }
+}
+
+void DataQueueFeeder::DrainAndClose() {
+  if (done) return;
+  done = true;
+  // do not do this several time, and note,
+  // it may be called several times.
+  while (!pendingPulls_.empty()) {
+    auto& pending = pendingPulls_.front();
+    auto pop = OnScopeLeave([this] { pendingPulls_.pop_front(); });
+    pending.next(bob::STATUS_EOS, nullptr, 0, [](uint64_t) {});
+  }
+  if (!readFinish_.IsEmpty()) {
+    Local<Promise::Resolver> resolver = readFinish_.Get(env()->isolate());
+    (void)resolver->Resolve(env()->context(), v8::False(env()->isolate()));
+    readFinish_.Reset();
+  }
+}
+
 }  // namespace node
 
 #endif  // defined(NODE_WANT_INTERNALS) && NODE_WANT_INTERNALS