From 01efbd8c94261ed0cec4c2939891f3ca050e5f02 Mon Sep 17 00:00:00 2001
From: Hayodea Hekol <hayodea@protonmail.com>
Date: Mon, 29 Jun 2026 00:21:45 -0400
Subject: [PATCH] Add sscl::co::syncAwaitNonViralCoro for blocking non-viral
 coroutine launch.

Co-authored-by: Cursor <cursoragent@cursor.com>
---
 include/spinscale/co/syncAwaitNonViralCoro.h | 43 ++++++++++++++++++++
 1 file changed, 43 insertions(+)
 create mode 100644 include/spinscale/co/syncAwaitNonViralCoro.h

diff --git a/include/spinscale/co/syncAwaitNonViralCoro.h b/include/spinscale/co/syncAwaitNonViralCoro.h
new file mode 100644
index 0000000..69d4b12
--- /dev/null
+++ b/include/spinscale/co/syncAwaitNonViralCoro.h
@@ -0,0 +1,43 @@
+#ifndef SYNC_AWAIT_NON_VIRAL_CORO_H
+#define SYNC_AWAIT_NON_VIRAL_CORO_H
+
+#include <boostAsioLinkageFix.h>
+
+#include <spinscale/componentThread.h>
+#include <spinscale/co/nonViralTaskNursery.h>
+#include <exception>
+#include <functional>
+
+namespace sscl::co {
+
+/** Launch a non-viral coroutine on the current ComponentThread io_context and
+ * block until it settles, rethrowing any stored exception.
+ */
+template<typename InvokerFactory>
+void syncAwaitNonViralCoro(InvokerFactory&& _invokerFactory)
+{
+	std::exception_ptr slotException;
+
+	NonViralTaskNursery nursery;
+	nursery.openAdmission();
+	nursery.launch(
+		[&_invokerFactory](NonViralTaskNursery::Slot::Lease& lease)
+		{
+			return _invokerFactory(lease);
+		},
+		[&slotException](std::exception_ptr& exceptionPtr)
+		{
+			slotException = exceptionPtr;
+		});
+	nursery.closeAdmission();
+	nursery.syncAwaitAllSettlements(
+		sscl::ComponentThread::getSelf()->getIoContext());
+
+	if (slotException) {
+		std::rethrow_exception(slotException);
+	}
+}
+
+} // namespace sscl::co
+
+#endif // SYNC_AWAIT_NON_VIRAL_CORO_H