45 NodeStatus child_state = child_node_->executeTick();
54 status_to_be_returned = child_state;
58 std::shared_ptr<ProtectedQueue<T>> queue;
59 if(getInput(
"queue", queue) && queue)
61 std::unique_lock<std::mutex> lk(queue->mtx);
62 auto& items = queue->items;
68 T val = items.front();
70 setOutput(
"popped_item", val);
73 NodeStatus child_state = child_node_->executeTick();
88 status_to_be_returned = child_state;
93 return status_to_be_returned;
98 return { InputPort<std::shared_ptr<ProtectedQueue<T>>>(
"queue"), OutputPort<T>(
"poppe"
105 bool running_child_ =
false;