File tree Expand file tree Collapse file tree 2 files changed +0
-4
lines changed
Expand file tree Collapse file tree 2 files changed +0
-4
lines changed Original file line number Diff line number Diff line change @@ -1269,13 +1269,11 @@ void DataQueue::RegisterExternalReferences(
12691269 // Nothing to do here currently.
12701270}
12711271
1272-
12731272DataQueueFeeder::DataQueueFeeder (Environment* env, Local<Object> object)
12741273 : AsyncWrap(env, object) {
12751274 MakeWeak ();
12761275}
12771276
1278-
12791277void DataQueueFeeder::tryWakePulls () {
12801278 if (!readFinish_.IsEmpty ()) {
12811279 v8::Local<v8::Promise::Resolver> resolver =
Original file line number Diff line number Diff line change @@ -317,7 +317,6 @@ class DataQueue : public MemoryRetainer {
317317 static void RegisterExternalReferences (ExternalReferenceRegistry* registry);
318318};
319319
320-
321320class DataQueueFeeder final : public AsyncWrap {
322321 public:
323322 using Next = bob::Next<DataQueue::Vec>;
@@ -331,7 +330,6 @@ class DataQueueFeeder final : public AsyncWrap {
331330
332331 void setDataQueue (std::shared_ptr<DataQueue> queue) { dataQueue_ = queue; }
333332
334-
335333 void clearPendingNext () { pendingPulls_.clear (); }
336334
337335 struct PendingPull {
You can’t perform that action at this time.
0 commit comments