Migrated transaction triggers

koenbeuk · koenbeuk · commit 7c931941a478 · 2022-10-21T00:54:29.000+01:00
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IAfterCommitAsyncTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IAfterCommitAsyncTrigger.cs
@@ -0,0 +1,11 @@
+﻿using System.Threading;
+using System.Threading.Tasks;
+
+namespace EntityFrameworkCore.Triggered.Transactions
+{
+    public interface IAfterCommitAsyncTrigger<in TEntity>
+        where TEntity : class
+    {
+        Task AfterCommitAsync(ITriggerContext<TEntity> context, CancellationToken cancellationToken);
+    }
+}
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IAfterCommitTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IAfterCommitTrigger.cs
@@ -6,6 +6,6 @@ namespace EntityFrameworkCore.Triggered.Transactions
     public interface IAfterCommitTrigger<in TEntity>
         where TEntity : class
     {
-        Task AfterCommit(ITriggerContext<TEntity> context, CancellationToken cancellationToken);
+        void AfterCommit(ITriggerContext<TEntity> context);
     }
 }
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IAfterRollbackAsyncTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IAfterRollbackAsyncTrigger.cs
@@ -0,0 +1,11 @@
+﻿using System.Threading;
+using System.Threading.Tasks;
+
+namespace EntityFrameworkCore.Triggered.Transactions
+{
+    public interface IAfterRollbackAsyncTrigger<in TEntity>
+        where TEntity : class
+    {
+        Task AfterRollbackAsync(ITriggerContext<TEntity> context, CancellationToken cancellationToken);
+    }
+}
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IAfterRollbackTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IAfterRollbackTrigger.cs
@@ -6,6 +6,6 @@ namespace EntityFrameworkCore.Triggered.Transactions
     public interface IAfterRollbackTrigger<in TEntity>
         where TEntity : class
     {
-        Task AfterRollback(ITriggerContext<TEntity> context, CancellationToken cancellationToken);
+        void AfterRollback(ITriggerContext<TEntity> context);
     }
 }
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IBeforeCommitAsyncTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IBeforeCommitAsyncTrigger.cs
@@ -0,0 +1,11 @@
+﻿using System.Threading;
+using System.Threading.Tasks;
+
+namespace EntityFrameworkCore.Triggered.Transactions
+{
+    public interface IBeforeCommitAsyncTrigger<in TEntity>
+        where TEntity : class
+    {
+        Task BeforeCommitAsync(ITriggerContext<TEntity> context, CancellationToken cancellationToken);
+    }
+}
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IBeforeCommitTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IBeforeCommitTrigger.cs
@@ -6,6 +6,6 @@ namespace EntityFrameworkCore.Triggered.Transactions
     public interface IBeforeCommitTrigger<in TEntity>
         where TEntity : class
     {
-        Task BeforeCommit(ITriggerContext<TEntity> context, CancellationToken cancellationToken);
+        void BeforeCommit(ITriggerContext<TEntity> context);
     }
 }
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IBeforeRollbackAsyncTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IBeforeRollbackAsyncTrigger.cs
@@ -0,0 +1,11 @@
+﻿using System.Threading;
+using System.Threading.Tasks;
+
+namespace EntityFrameworkCore.Triggered.Transactions
+{
+    public interface IBeforeRollbackAsyncTrigger<in TEntity>
+        where TEntity : class
+    {
+        Task BeforeRollbackAsync(ITriggerContext<TEntity> context, CancellationToken cancellationToken);
+    }
+}
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IBeforeRollbackTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/IBeforeRollbackTrigger.cs
@@ -1,11 +1,8 @@
-﻿using System.Threading;
-using System.Threading.Tasks;
-
-namespace EntityFrameworkCore.Triggered.Transactions
+﻿namespace EntityFrameworkCore.Triggered.Transactions
 {
     public interface IBeforeRollbackTrigger<in TEntity>
         where TEntity : class
     {
-        Task BeforeRollback(ITriggerContext<TEntity> context, CancellationToken cancellationToken);
+        void BeforeRollback(ITriggerContext<TEntity> context);
     }
 }
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IAfterCommitCompletedAsyncTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IAfterCommitCompletedAsyncTrigger.cs
@@ -0,0 +1,10 @@
+﻿using System.Threading;
+using System.Threading.Tasks;
+
+namespace EntityFrameworkCore.Triggered.Transactions.Lifecycles
+{
+    public interface IAfterCommitCompletedAsyncTrigger
+    {
+        Task AfterCommitCompletedAsync(CancellationToken cancellationToken);
+    }
+}
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IAfterCommitCompletedTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IAfterCommitCompletedTrigger.cs
@@ -5,6 +5,6 @@ namespace EntityFrameworkCore.Triggered.Transactions.Lifecycles
 {
     public interface IAfterCommitCompletedTrigger
     {
-        Task AfterCommitCompleted(CancellationToken cancellationToken);
+        void AfterCommitCompleted();
     }
 }
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IAfterCommitStartingAsyncTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IAfterCommitStartingAsyncTrigger.cs
@@ -0,0 +1,10 @@
+﻿using System.Threading;
+using System.Threading.Tasks;
+
+namespace EntityFrameworkCore.Triggered.Transactions.Lifecycles
+{
+    public interface IAfterCommitStartingAsyncTrigger
+    {
+        Task AfterCommitStartingAsync(CancellationToken cancellationToken);
+    }
+}
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IAfterCommitStartingTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IAfterCommitStartingTrigger.cs
@@ -5,6 +5,6 @@ namespace EntityFrameworkCore.Triggered.Transactions.Lifecycles
 {
     public interface IAfterCommitStartingTrigger
     {
-        Task AfterCommitStarting(CancellationToken cancellationToken);
+        void AfterCommitStarting();
     }
 }
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IBeforeCommitCompletedAsyncTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IBeforeCommitCompletedAsyncTrigger.cs
@@ -0,0 +1,10 @@
+﻿using System.Threading;
+using System.Threading.Tasks;
+
+namespace EntityFrameworkCore.Triggered.Transactions.Lifecycles
+{
+    public interface IBeforeCommitCompletedAsyncTrigger
+    {
+        Task BeforeCommitCompletedAsync(CancellationToken cancellationToken);
+    }
+}
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IBeforeCommitCompletedTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IBeforeCommitCompletedTrigger.cs
@@ -5,6 +5,6 @@ namespace EntityFrameworkCore.Triggered.Transactions.Lifecycles
 {
     public interface IBeforeCommitCompletedTrigger
     {
-        Task BeforeCommitCompleted(CancellationToken cancellationToken);
+        void BeforeCommitCompleted();
     }
 }
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IBeforeCommitStartingAsyncTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IBeforeCommitStartingAsyncTrigger.cs
@@ -0,0 +1,10 @@
+﻿using System.Threading;
+using System.Threading.Tasks;
+
+namespace EntityFrameworkCore.Triggered.Transactions.Lifecycles
+{
+    public interface IBeforeCommitStartingAsyncTrigger
+    {
+        Task BeforeCommitStartingAsync(CancellationToken cancellationToken);
+    }
+}
diff --git a/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IBeforeCommitStartingTrigger.cs b/src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/IBeforeCommitStartingTrigger.cs
@@ -5,6 +5,6 @@ namespace EntityFrameworkCore.Triggered.Transactions.Lifecycles
 {
     public interface IBeforeCommitStartingTrigger
     {
-        Task BeforeCommitStarting(CancellationToken cancellationToken);
+        void BeforeCommitStarting();
     }
 }
diff --git a/src/EntityFrameworkCore.Triggered.Transactions/Extensions/TriggersContextOptionsBuilderExtensions.cs b/src/EntityFrameworkCore.Triggered.Transactions/Extensions/TriggersContextOptionsBuilderExtensions.cs
@@ -16,13 +16,21 @@ public static TriggersContextOptionsBuilder UseTransactionTriggers(this Triggers
 
             return triggersContextOptionsBuilder
                 .AddTriggerType(typeof(IBeforeCommitTrigger<>))
+                .AddTriggerType(typeof(IBeforeCommitAsyncTrigger<>))
                 .AddTriggerType(typeof(IAfterCommitTrigger<>))
+                .AddTriggerType(typeof(IAfterCommitAsyncTrigger<>))
                 .AddTriggerType(typeof(IBeforeRollbackTrigger<>))
+                .AddTriggerType(typeof(IBeforeRollbackAsyncTrigger<>))
                 .AddTriggerType(typeof(IAfterRollbackTrigger<>))
+                .AddTriggerType(typeof(IAfterRollbackAsyncTrigger<>))
                 .AddTriggerType(typeof(IBeforeCommitStartingTrigger))
+                .AddTriggerType(typeof(IBeforeCommitStartingAsyncTrigger))
                 .AddTriggerType(typeof(IBeforeCommitCompletedTrigger))
+                .AddTriggerType(typeof(IBeforeCommitCompletedAsyncTrigger))
                 .AddTriggerType(typeof(IAfterCommitStartingTrigger))
-                .AddTriggerType(typeof(IAfterCommitCompletedTrigger));
+                .AddTriggerType(typeof(IAfterCommitStartingAsyncTrigger))
+                .AddTriggerType(typeof(IAfterCommitCompletedTrigger))
+                .AddTriggerType(typeof(IAfterCommitCompletedAsyncTrigger));
         }
     }
 }
diff --git a/src/EntityFrameworkCore.Triggered.Transactions/Internal/AfterCommitAsyncTriggerDescriptor.cs b/src/EntityFrameworkCore.Triggered.Transactions/Internal/AfterCommitAsyncTriggerDescriptor.cs
@@ -0,0 +1,33 @@
+﻿using System;
+using System.Diagnostics;
+using System.Threading;
+using System.Threading.Tasks;
+using EntityFrameworkCore.Triggered.Internal;
+using EntityFrameworkCore.Triggered.Internal.Descriptors;
+
+namespace EntityFrameworkCore.Triggered.Transactions.Internal
+{
+    public class AfterCommitAsyncTriggerDescriptor : IAsyncTriggerTypeDescriptor
+    {
+        readonly Func<object, object, CancellationToken, Task> _invocationDelegate;
+        readonly Type _triggerType;
+
+        public AfterCommitAsyncTriggerDescriptor(Type entityType)
+        {
+            var triggerType = typeof(IAfterCommitAsyncTrigger<>).MakeGenericType(entityType);
+            var triggerMethod = triggerType.GetMethod(nameof(IAfterCommitAsyncTrigger<object>.AfterCommitAsync));
+
+            _triggerType = triggerType;
+            _invocationDelegate = TriggerTypeDescriptorHelpers.GetAsyncWeakDelegate(triggerType, entityType, triggerMethod!);
+        }
+
+        public Type TriggerType => _triggerType;
+
+        public Task Invoke(object trigger, object triggerContext, Exception? exception, CancellationToken cancellationToken)
+        {
+            Debug.Assert(exception == null);
+
+            return _invocationDelegate(trigger, triggerContext, cancellationToken);
+        }
+    }
+}
diff --git a/src/EntityFrameworkCore.Triggered.Transactions/Internal/AfterCommitTriggerDescriptor.cs b/src/EntityFrameworkCore.Triggered.Transactions/Internal/AfterCommitTriggerDescriptor.cs
@@ -3,12 +3,13 @@
 using System.Threading;
 using System.Threading.Tasks;
 using EntityFrameworkCore.Triggered.Internal;
+using EntityFrameworkCore.Triggered.Internal.Descriptors;
 
 namespace EntityFrameworkCore.Triggered.Transactions.Internal
 {
     public class AfterCommitTriggerDescriptor : ITriggerTypeDescriptor
     {
-        readonly Func<object, object, CancellationToken, Task> _invocationDelegate;
+        readonly Action<object, object> _invocationDelegate;
         readonly Type _triggerType;
 
         public AfterCommitTriggerDescriptor(Type entityType)
@@ -17,17 +18,16 @@ public AfterCommitTriggerDescriptor(Type entityType)
             var triggerMethod = triggerType.GetMethod(nameof(IAfterCommitTrigger<object>.AfterCommit));
 
             _triggerType = triggerType;
-            _invocationDelegate = TriggerTypeDescriptorHelpers.GetAsyncWeakDelegate(triggerType, entityType, triggerMethod!);
+            _invocationDelegate = TriggerTypeDescriptorHelpers.GetWeakDelegate(triggerType, entityType, triggerMethod!);
         }
 
         public Type TriggerType => _triggerType;
 
-        public Task Invoke(object trigger, object triggerContext, Exception? exception, CancellationToken cancellationToken)
+        public void Invoke(object trigger, object triggerContext, Exception? exception)
         {
             Debug.Assert(exception == null);
 
-            return _invocationDelegate(trigger, triggerContext, cancellationToken);
+            _invocationDelegate(trigger, triggerContext);
         }
-
     }
 }
diff --git a/src/EntityFrameworkCore.Triggered.Transactions/Internal/AfterRollbackAsyncTriggerDescriptor.cs b/src/EntityFrameworkCore.Triggered.Transactions/Internal/AfterRollbackAsyncTriggerDescriptor.cs
@@ -0,0 +1,33 @@
+﻿using System;
+using System.Diagnostics;
+using System.Threading;
+using System.Threading.Tasks;
+using EntityFrameworkCore.Triggered.Internal;
+using EntityFrameworkCore.Triggered.Internal.Descriptors;
+
+namespace EntityFrameworkCore.Triggered.Transactions.Internal
+{
+    public class AfterRollbackAsyncTriggerDescriptor : IAsyncTriggerTypeDescriptor
+    {
+        readonly Func<object, object, CancellationToken, Task> _invocationDelegate;
+        readonly Type _triggerType;
+
+        public AfterRollbackAsyncTriggerDescriptor(Type entityType)
+        {
+            var triggerType = typeof(IAfterRollbackAsyncTrigger<>).MakeGenericType(entityType);
+            var triggerMethod = triggerType.GetMethod(nameof(IAfterRollbackAsyncTrigger<object>.AfterRollbackAsync));
+
+            _triggerType = triggerType;
+            _invocationDelegate = TriggerTypeDescriptorHelpers.GetAsyncWeakDelegate(triggerType, entityType, triggerMethod!);
+        }
+
+        public Type TriggerType => _triggerType;
+
+        public Task Invoke(object trigger, object triggerContext, Exception? exception, CancellationToken cancellationToken)
+        {
+            Debug.Assert(exception == null);
+
+            return _invocationDelegate(trigger, triggerContext, cancellationToken);
+        }
+    }
+}
diff --git a/src/EntityFrameworkCore.Triggered.Transactions/Internal/AfterRollbackTriggerDescriptor.cs b/src/EntityFrameworkCore.Triggered.Transactions/Internal/AfterRollbackTriggerDescriptor.cs
@@ -3,12 +3,13 @@
 using System.Threading;
 using System.Threading.Tasks;
 using EntityFrameworkCore.Triggered.Internal;
+using EntityFrameworkCore.Triggered.Internal.Descriptors;
 
 namespace EntityFrameworkCore.Triggered.Transactions.Internal
 {
     public class AfterRollbackTriggerDescriptor : ITriggerTypeDescriptor
     {
-        readonly Func<object, object, CancellationToken, Task> _invocationDelegate;
+        readonly Action<object, object> _invocationDelegate;
         readonly Type _triggerType;
 
         public AfterRollbackTriggerDescriptor(Type entityType)
@@ -17,16 +18,16 @@ public AfterRollbackTriggerDescriptor(Type entityType)
             var triggerMethod = triggerType.GetMethod(nameof(IAfterRollbackTrigger<object>.AfterRollback));
 
             _triggerType = triggerType;
-            _invocationDelegate = TriggerTypeDescriptorHelpers.GetAsyncWeakDelegate(triggerType, entityType, triggerMethod!);
+            _invocationDelegate = TriggerTypeDescriptorHelpers.GetWeakDelegate(triggerType, entityType, triggerMethod!);
         }
 
         public Type TriggerType => _triggerType;
 
-        public Task Invoke(object trigger, object triggerContext, Exception? exception, CancellationToken cancellationToken)
+        public void Invoke(object trigger, object triggerContext, Exception? exception)
         {
             Debug.Assert(exception == null);
 
-            return _invocationDelegate(trigger, triggerContext, cancellationToken);
+            _invocationDelegate(trigger, triggerContext);
         }
     }
 }
diff --git a/src/EntityFrameworkCore.Triggered.Transactions/Internal/BeforeCommitAsyncTriggerDescriptor.cs b/src/EntityFrameworkCore.Triggered.Transactions/Internal/BeforeCommitAsyncTriggerDescriptor.cs
@@ -0,0 +1,33 @@
+﻿using System;
+using System.Diagnostics;
+using System.Threading;
+using System.Threading.Tasks;
+using EntityFrameworkCore.Triggered.Internal;
+using EntityFrameworkCore.Triggered.Internal.Descriptors;
+
+namespace EntityFrameworkCore.Triggered.Transactions.Internal
+{
+    public class BeforeCommitAsyncTriggerDescriptor : IAsyncTriggerTypeDescriptor
+    {
+        readonly Func<object, object, CancellationToken, Task> _invocationDelegate;
+        readonly Type _triggerType;
+
+        public BeforeCommitAsyncTriggerDescriptor(Type entityType)
+        {
+            var triggerType = typeof(IBeforeCommitAsyncTrigger<>).MakeGenericType(entityType);
+            var triggerMethod = triggerType.GetMethod(nameof(IBeforeCommitAsyncTrigger<object>.BeforeCommitAsync));
+
+            _triggerType = triggerType;
+            _invocationDelegate = TriggerTypeDescriptorHelpers.GetAsyncWeakDelegate(triggerType, entityType, triggerMethod!);
+        }
+
+        public Type TriggerType => _triggerType;
+
+        public Task Invoke(object trigger, object triggerContext, Exception? exception, CancellationToken cancellationToken)
+        {
+            Debug.Assert(exception == null);
+
+            return _invocationDelegate(trigger, triggerContext, cancellationToken);
+        }
+    }
+}
diff --git a/src/EntityFrameworkCore.Triggered.Transactions/Internal/BeforeCommitTriggerDescriptor.cs b/src/EntityFrameworkCore.Triggered.Transactions/Internal/BeforeCommitTriggerDescriptor.cs
@@ -3,12 +3,13 @@
 using System.Threading;
 using System.Threading.Tasks;
 using EntityFrameworkCore.Triggered.Internal;
+using EntityFrameworkCore.Triggered.Internal.Descriptors;
 
 namespace EntityFrameworkCore.Triggered.Transactions.Internal
 {
     public class BeforeCommitTriggerDescriptor : ITriggerTypeDescriptor
     {
-        readonly Func<object, object, CancellationToken, Task> _invocationDelegate;
+        readonly Action<object, object> _invocationDelegate;
         readonly Type _triggerType;
 
         public BeforeCommitTriggerDescriptor(Type entityType)
@@ -17,16 +18,16 @@ public BeforeCommitTriggerDescriptor(Type entityType)
             var triggerMethod = triggerType.GetMethod(nameof(IBeforeCommitTrigger<object>.BeforeCommit));
 
             _triggerType = triggerType;
-            _invocationDelegate = TriggerTypeDescriptorHelpers.GetAsyncWeakDelegate(triggerType, entityType, triggerMethod!);
+            _invocationDelegate = TriggerTypeDescriptorHelpers.GetWeakDelegate(triggerType, entityType, triggerMethod!);
         }
 
         public Type TriggerType => _triggerType;
 
-        public Task Invoke(object trigger, object triggerContext, Exception? exception, CancellationToken cancellationToken)
+        public void Invoke(object trigger, object triggerContext, Exception? exception)
         {
             Debug.Assert(exception == null);
 
-            return _invocationDelegate(trigger, triggerContext, cancellationToken);
+            _invocationDelegate(trigger, triggerContext);
         }
     }
 }
diff --git a/src/EntityFrameworkCore.Triggered.Transactions/Internal/BeforeRollbackAsyncTriggerDescriptor.cs b/src/EntityFrameworkCore.Triggered.Transactions/Internal/BeforeRollbackAsyncTriggerDescriptor.cs
diff --git a/src/EntityFrameworkCore.Triggered.Transactions/Internal/BeforeRollbackTriggerDescriptor.cs b/src/EntityFrameworkCore.Triggered.Transactions/Internal/BeforeRollbackTriggerDescriptor.cs
diff --git a/src/EntityFrameworkCore.Triggered.Transactions/TriggeredSessionExtensions.cs b/src/EntityFrameworkCore.Triggered.Transactions/TriggeredSessionExtensions.cs
diff --git a/test/EntityFrameworkCore.Triggered.Transactions.Tests/Internal/AfterCommitTriggerDescriptorTests.cs b/test/EntityFrameworkCore.Triggered.Transactions.Tests/Internal/AfterCommitTriggerDescriptorTests.cs
diff --git a/test/EntityFrameworkCore.Triggered.Transactions.Tests/Internal/AfterRollbackTriggerDescriptorTests.cs b/test/EntityFrameworkCore.Triggered.Transactions.Tests/Internal/AfterRollbackTriggerDescriptorTests.cs
diff --git a/test/EntityFrameworkCore.Triggered.Transactions.Tests/Internal/BeforeCommitTriggerDescriptorTests.cs b/test/EntityFrameworkCore.Triggered.Transactions.Tests/Internal/BeforeCommitTriggerDescriptorTests.cs
diff --git a/test/EntityFrameworkCore.Triggered.Transactions.Tests/Internal/BeforeRollbackTriggerDescriptorTests.cs b/test/EntityFrameworkCore.Triggered.Transactions.Tests/Internal/BeforeRollbackTriggerDescriptorTests.cs
diff --git a/test/EntityFrameworkCore.Triggered.Transactions.Tests/Stubs/TriggerStub.cs b/test/EntityFrameworkCore.Triggered.Transactions.Tests/Stubs/TriggerStub.cs
diff --git a/test/EntityFrameworkCore.Triggered.Transactions.Tests/TriggeredDbContextTests.cs b/test/EntityFrameworkCore.Triggered.Transactions.Tests/TriggeredDbContextTests.cs
diff --git a/test/EntityFrameworkCore.Triggered.Transactions.Tests/TriggeredSessionExtensionsTests.cs b/test/EntityFrameworkCore.Triggered.Transactions.Tests/TriggeredSessionExtensionsTests.cs

Original file line number	Diff line number	Diff line change
`@@ -6,6 +6,6 @@ namespace EntityFrameworkCore.Triggered.Transactions`
`6`	`6`	`public interface IAfterCommitTrigger<in TEntity>`
`7`	`7`	`where TEntity : class`
`8`	`8`	`{`
`9`		`- Task AfterCommit(ITriggerContext<TEntity> context, CancellationToken cancellationToken);`
	`9`	`+ void AfterCommit(ITriggerContext<TEntity> context);`
`10`	`10`	`}`
`11`	`11`	`}`
Original file line number	Diff line number	Diff line change
`@@ -6,6 +6,6 @@ namespace EntityFrameworkCore.Triggered.Transactions`
`6`	`6`	`public interface IAfterRollbackTrigger<in TEntity>`
`7`	`7`	`where TEntity : class`
`8`	`8`	`{`
`9`		`- Task AfterRollback(ITriggerContext<TEntity> context, CancellationToken cancellationToken);`
	`9`	`+ void AfterRollback(ITriggerContext<TEntity> context);`
`10`	`10`	`}`
`11`	`11`	`}`
Original file line number	Diff line number	Diff line change
`@@ -6,6 +6,6 @@ namespace EntityFrameworkCore.Triggered.Transactions`
`6`	`6`	`public interface IBeforeCommitTrigger<in TEntity>`
`7`	`7`	`where TEntity : class`
`8`	`8`	`{`
`9`		`- Task BeforeCommit(ITriggerContext<TEntity> context, CancellationToken cancellationToken);`
	`9`	`+ void BeforeCommit(ITriggerContext<TEntity> context);`
`10`	`10`	`}`
`11`	`11`	`}`
Original file line number	Diff line number	Diff line change
`@@ -1,11 +1,8 @@`
`1`		`-using System.Threading;`
`2`		`-using System.Threading.Tasks;`
`3`		`-`
`4`		`-namespace EntityFrameworkCore.Triggered.Transactions`
	`1`	`+namespace EntityFrameworkCore.Triggered.Transactions`
`5`	`2`	`{`
`6`	`3`	`public interface IBeforeRollbackTrigger<in TEntity>`
`7`	`4`	`where TEntity : class`
`8`	`5`	`{`
`9`		`- Task BeforeRollback(ITriggerContext<TEntity> context, CancellationToken cancellationToken);`
	`6`	`+ void BeforeRollback(ITriggerContext<TEntity> context);`
`10`	`7`	`}`
`11`	`8`	`}`
Original file line number	Diff line number	Diff line change
`@@ -5,6 +5,6 @@ namespace EntityFrameworkCore.Triggered.Transactions.Lifecycles`
`5`	`5`	`{`
`6`	`6`	`public interface IAfterCommitCompletedTrigger`
`7`	`7`	`{`
`8`		`- Task AfterCommitCompleted(CancellationToken cancellationToken);`
	`8`	`+ void AfterCommitCompleted();`
`9`	`9`	`}`
`10`	`10`	`}`