diff --git a/DigitalData.Core.Abstractions/Infrastructure/IRepository.cs b/DigitalData.Core.Abstractions/Infrastructure/IRepository.cs
index fbd9581..781a1e2 100644
--- a/DigitalData.Core.Abstractions/Infrastructure/IRepository.cs
+++ b/DigitalData.Core.Abstractions/Infrastructure/IRepository.cs
@@ -4,13 +4,13 @@ namespace DigitalData.Core.Abstractions.Infrastructure;
 
 public interface IRepository<TEntity>
 {
-    public Task<TEntity> CreateAsync<TDto>(TDto dto);
+    public Task<TEntity> CreateAsync<TDto>(TDto dto, CancellationToken ct = default);
 
-    public Task<TEntity> CreateAsync<TDto>(IEnumerable<TDto> dtos);
+    public Task<TEntity> CreateAsync<TDto>(IEnumerable<TDto> dtos, CancellationToken ct = default);
 
-    public Task<IEnumerable<TEntity>> ReadAsync(Expression? expression = null);
+    public Task<IEnumerable<TEntity>> ReadAsync(Expression? expression = null, CancellationToken ct = default);
 
-    public Task<IEnumerable<TEntity>> UpdateAsync<TDto>(TDto dto, Expression expression);
+    public Task<IEnumerable<TEntity>> UpdateAsync<TDto>(TDto dto, Expression expression, CancellationToken ct = default);
 
-    public Task<IEnumerable<TEntity>> DeleteAsync<TDto>(Expression expression);
+    public Task<IEnumerable<TEntity>> DeleteAsync<TDto>(Expression expression, CancellationToken ct = default);
 }
diff --git a/DigitalData.Core.Infrastructure/DbRepository.cs b/DigitalData.Core.Infrastructure/DbRepository.cs
index c5be39b..61a70da 100644
--- a/DigitalData.Core.Infrastructure/DbRepository.cs
+++ b/DigitalData.Core.Infrastructure/DbRepository.cs
@@ -16,27 +16,27 @@ public class DbRepository<TDbContext, TEntity> : IRepository<TEntity> where TDbC
         Entities = queryFactory(context);
     }
 
-    public Task<TEntity> CreateAsync<TDto>(TDto dto)
+    public Task<TEntity> CreateAsync<TDto>(TDto dto, CancellationToken ct = default)
     {
         throw new NotImplementedException();
     }
 
-    public Task<TEntity> CreateAsync<TDto>(IEnumerable<TDto> dtos)
+    public Task<TEntity> CreateAsync<TDto>(IEnumerable<TDto> dtos, CancellationToken ct = default)
     {
         throw new NotImplementedException();
     }
 
-    public Task<IEnumerable<TEntity>> DeleteAsync<TDto>(Expression expression)
+    public Task<IEnumerable<TEntity>> DeleteAsync<TDto>(Expression expression, CancellationToken ct = default)
     {
         throw new NotImplementedException();
     }
 
-    public Task<IEnumerable<TEntity>> ReadAsync(Expression? expression = null)
+    public Task<IEnumerable<TEntity>> ReadAsync(Expression? expression = null, CancellationToken ct = default)
     {
         throw new NotImplementedException();
     }
 
-    public Task<IEnumerable<TEntity>> UpdateAsync<TDto>(TDto dto, Expression expression)
+    public Task<IEnumerable<TEntity>> UpdateAsync<TDto>(TDto dto, Expression expression, CancellationToken ct = default)
     {
         throw new NotImplementedException();
     }