Added ISubscribeTo interface

stidsborg · May 4, 2024 · 9653be8 · 9653be8
1 parent 1f182b6
commit 9653be8
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/Cleipnir.Flows/ISubscribeTo.cs b/Cleipnir.Flows/ISubscribeTo.cs
@@ -0,0 +1,11 @@
+using System.Threading.Tasks;
+
+namespace Cleipnir.Flows;
+
+public delegate Task BusPublish(object msg);
+
+public interface ISubscribeTo<TMessage>
+{
+    public BusPublish PublishOnBus(object msg);
+    static abstract string Correlate(TMessage msg);
+}