@@ -1902,42 +1902,42 @@ AwaitableUnsubscribe Request::unsubscribe(RequestUnsubscribeParams params)
1902
1902
throw std::logic_error (" Subscriptions not supported" );
1903
1903
}
1904
1904
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
+ // }
1934
1934
1935
1935
spThis->removeSubscription (params.key );
1936
1936
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
+ // }
1941
1941
1942
1942
co_return ;
1943
1943
}
0 commit comments