Skip to content

Commit 2129e86

Browse files
author
Rafał Hibner
committed
Merge branch 'cherry-pick-9edb8c5e' into 'namechange'
Skip unsubscribe notify See merge request zynqmp/cppgraphqlgen!2
2 parents 6375adf + 350486e commit 2129e86

File tree

1 file changed

+33
-33
lines changed

1 file changed

+33
-33
lines changed

src/GraphQLService.cpp

Lines changed: 33 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -1902,42 +1902,42 @@ AwaitableUnsubscribe Request::unsubscribe(RequestUnsubscribeParams params)
19021902
throw std::logic_error("Subscriptions not supported");
19031903
}
19041904

1905-
const auto optionalOrDefaultSubscription =
1906-
params.subscriptionObject ? std::move(params.subscriptionObject) : itrOperation->second;
1907-
std::list<schema_error> errors {};
1908-
1909-
if (optionalOrDefaultSubscription)
1910-
{
1911-
const auto registration = spThis->_subscriptions.at(params.key);
1912-
const SelectionSetParams selectionSetParams {
1913-
ResolverContext::NotifyUnsubscribe,
1914-
registration->data->state,
1915-
registration->data->directives,
1916-
std::make_shared<FragmentDefinitionDirectiveStack>(),
1917-
std::make_shared<FragmentSpreadDirectiveStack>(),
1918-
std::make_shared<FragmentSpreadDirectiveStack>(),
1919-
{},
1920-
params.launch,
1921-
};
1922-
1923-
lock.unlock();
1924-
1925-
co_await params.launch;
1926-
errors = std::move((co_await optionalOrDefaultSubscription->resolve(selectionSetParams,
1927-
registration->selection,
1928-
registration->data->fragments,
1929-
registration->data->variables))
1930-
.errors);
1931-
1932-
lock.lock();
1933-
}
1905+
// const auto optionalOrDefaultSubscription =
1906+
// params.subscriptionObject ? std::move(params.subscriptionObject) : itrOperation->second;
1907+
// std::list<schema_error> errors {};
1908+
1909+
// if (optionalOrDefaultSubscription)
1910+
// {
1911+
// const auto registration = spThis->_subscriptions.at(params.key);
1912+
// const SelectionSetParams selectionSetParams {
1913+
// ResolverContext::NotifyUnsubscribe,
1914+
// registration->data->state,
1915+
// registration->data->directives,
1916+
// std::make_shared<FragmentDefinitionDirectiveStack>(),
1917+
// std::make_shared<FragmentSpreadDirectiveStack>(),
1918+
// std::make_shared<FragmentSpreadDirectiveStack>(),
1919+
// {},
1920+
// params.launch,
1921+
// };
1922+
1923+
// lock.unlock();
1924+
1925+
// co_await params.launch;
1926+
// errors = std::move((co_await optionalOrDefaultSubscription->resolve(selectionSetParams,
1927+
// registration->selection,
1928+
// registration->data->fragments,
1929+
// registration->data->variables))
1930+
// .errors);
1931+
1932+
// lock.lock();
1933+
// }
19341934

19351935
spThis->removeSubscription(params.key);
19361936

1937-
if (!errors.empty())
1938-
{
1939-
throw schema_exception { std::move(errors) };
1940-
}
1937+
// if (!errors.empty())
1938+
// {
1939+
// throw schema_exception { std::move(errors) };
1940+
// }
19411941

19421942
co_return;
19431943
}

0 commit comments

Comments
 (0)