@@ -26,8 +26,9 @@ public:
2626 * Set async error callback. If callback is already set it will be
2727 * overwritten.
2828 */
29- auto set_async_error_callback (async_error_callback_t callback)
30- -> async_events_collector& {
29+ auto set_async_error_callback ( //
30+ async_error_callback_t callback
31+ ) -> async_events_collector& {
3132 _async_error_cb = std::move (callback);
3233 return *this ;
3334 }
@@ -36,8 +37,9 @@ public:
3637 * Set async error callback. If callback is already set it will be
3738 * overwritten.
3839 */
39- auto set_system_error_callback (system_error_callback_t callback)
40- -> async_events_collector& {
40+ auto set_system_error_callback ( //
41+ system_error_callback_t callback
42+ ) -> async_events_collector& {
4143 _system_error_cb = std::move (callback);
4244 return *this ;
4345 }
@@ -46,8 +48,9 @@ public:
4648 * Set async error callback. If callback is already set it will be
4749 * overwritten.
4850 */
49- auto set_async_requests_done_callback (async_requests_done_callback_t callback)
50- -> async_events_collector& {
51+ auto set_async_requests_done_callback ( //
52+ async_requests_done_callback_t callback
53+ ) -> async_events_collector& {
5154 _async_requests_done_cb = std::move (callback);
5255 return *this ;
5356 }
@@ -136,8 +139,9 @@ private:
136139 }
137140};
138141
139- [[nodiscard]] inline auto connect (const std::string& connection_string)
140- -> ecsact_async_request_id {
142+ [[nodiscard]] inline auto connect ( //
143+ const std::string& connection_string
144+ ) -> ecsact_async_request_id {
141145 return ecsact_async_connect (connection_string.c_str ());
142146}
143147
@@ -161,17 +165,17 @@ inline auto flush_events() -> void {
161165
162166template <typename ExecutionEventsCollector>
163167 requires (std::convertible_to<
164- decltype (std::declval<ExecutionEventsCollector>().c()),
165- const ecsact_execution_events_collector>)
168+ decltype (std::declval<ExecutionEventsCollector>().c()),
169+ const ecsact_execution_events_collector>)
166170inline auto flush_events(ExecutionEventsCollector&& evc) -> void {
167171 const ecsact_execution_events_collector evc_c = evc.c ();
168172 ecsact_async_flush_events (&evc_c, nullptr );
169173}
170174
171175template <typename AsyncEventsCollector>
172176 requires (std::convertible_to<
173- decltype (std::declval<AsyncEventsCollector>().c()),
174- const ecsact_async_events_collector>)
177+ decltype (std::declval<AsyncEventsCollector>().c()),
178+ const ecsact_async_events_collector>)
175179inline auto flush_events(AsyncEventsCollector&& async_evc) -> void {
176180 const ecsact_async_events_collector async_evc_c = async_evc.c ();
177181 ecsact_async_flush_events (nullptr , &async_evc_c);
0 commit comments