Ensure AsyncWorker options are persisted #2130

This commit is contained in:
Lovell Fuller
2020-03-19 21:21:21 +00:00
parent c1d4a68558
commit e82a585cec
4 changed files with 6 additions and 0 deletions

View File

@@ -229,6 +229,7 @@ Napi::Value metadata(const Napi::CallbackInfo& info) {
// Join queue for worker thread
Napi::Function callback = info[1].As<Napi::Function>();
MetadataWorker *worker = new MetadataWorker(callback, baton, debuglog);
worker->Receiver().Set("options", options);
worker->Queue();
// Increment queued task counter

View File

@@ -1360,6 +1360,7 @@ Napi::Value pipeline(const Napi::CallbackInfo& info) {
// Join queue for worker thread
Napi::Function callback = info[1].As<Napi::Function>();
PipelineWorker *worker = new PipelineWorker(callback, baton, debuglog, queueListener);
worker->Receiver().Set("options", options);
worker->Queue();
// Increment queued task counter

View File

@@ -154,6 +154,7 @@ Napi::Value stats(const Napi::CallbackInfo& info) {
// Join queue for worker thread
Napi::Function callback = info[1].As<Napi::Function>();
StatsWorker *worker = new StatsWorker(callback, baton, debuglog);
worker->Receiver().Set("options", options);
worker->Queue();
// Increment queued task counter