k2snowman69 / threadily Goto Github PK

        TEST_METHOD(ThreadObject_Observable_Vector_ThreadObject)
        {
            auto threadManager = std::make_shared<ThreadManager>();
            threadManager->getOrCreateThread(ThreadIds::Service, std::set<unsigned int>({ ThreadIds::App }));
            threadManager->getOrCreateThread(ThreadIds::App, std::set<unsigned int>({ ThreadIds::UI }));
            threadManager->getOrCreateThread(ThreadIds::UI);

            auto threadObjectManager = std::make_shared<ThreadObjectManager<ParentThreadObject>>(threadManager);
            auto childThreadObjectManager = std::make_shared<ThreadObjectManager<ExampleThreadObject>>(threadManager);
            auto threadObject_UI = threadObjectManager->getOrCreateObject(ThreadIds::UI, 0);
            auto threadObject_Service = threadObjectManager->getOrCreateObject(ThreadIds::Service, 0);

            // set up a waiter until we get a notification on the UI thread that something has been completed
            ReadyEvent e;
            auto subscribeHandle = threadObject_UI->exampleObjects->subscribe([&e](std::shared_ptr<ExampleThreadObject> newValue, size_t index, ObservableActionType action)
            {
                e.finished();
            });

            auto sizeBefore = threadObject_UI->exampleObjects->size();

            auto newChildObject = childThreadObjectManager->getOrCreateObject(ThreadIds::Service, 4);
            newChildObject->name->set(L"new name");
            threadObject_Service->exampleObjects->insert(0, newChildObject);
            e.wait();

            Assert::IsTrue(nullptr != threadObject_UI->exampleObjects->at(0), L"Make sure the UI object was set");
            Assert::IsTrue(threadObject_UI->exampleObjects->size() == sizeBefore + 1, L"Expect example objects list to be size of 1");
            Assert::IsTrue(ThreadIds::UI == threadObject_UI->exampleObjects->at(0)->getThreadId(), L"Expected the example object to be running on the UI thread");
            Assert::IsTrue(ThreadIds::Service == threadObject_Service->exampleObjects->at(0)->getThreadId(), L"Expected the example object to be running on the Service thread");
            Assert::AreEqual(threadObject_UI->exampleObjects->at(0)->getId(), threadObject_Service->exampleObjects->at(0)->getId(), L"Make sure they have the same value");
            Assert::IsTrue(threadObject_UI->exampleObjects->at(0).get() != threadObject_Service->exampleObjects->at(0).get(), L"Make sure they are two distinct pointers");
            Assert::AreEqual(threadObject_UI->exampleObjects->at(0)->name->get(), threadObject_Service->exampleObjects->at(0)->name->get(), L"Make sure they have the same name value");
        }