diff --git a/src/node_messaging.cc b/src/node_messaging.cc index 7ca3ad14d03406..c9be44f4102816 100644 --- a/src/node_messaging.cc +++ b/src/node_messaging.cc @@ -494,10 +494,6 @@ MessagePort::MessagePort(Environment* env, Debug(this, "Created message port"); } -void MessagePort::AddToIncomingQueue(Message&& message) { - data_->AddToIncomingQueue(std::move(message)); -} - uv_async_t* MessagePort::async() { return reinterpret_cast(GetHandle()); } diff --git a/src/node_messaging.h b/src/node_messaging.h index 9055a8bf961844..00fd4d7f9f00f4 100644 --- a/src/node_messaging.h +++ b/src/node_messaging.h @@ -152,8 +152,6 @@ class MessagePort : public HandleWrap { v8::Maybe PostMessage(Environment* env, v8::Local message, v8::Local transfer); - // Deliver a single message into this port's incoming queue. - void AddToIncomingQueue(Message&& message); // Start processing messages on this port as a receiving end. void Start();