diff --git a/src/Fluss/UnitOfWork/IWriteUnitOfWork.cs b/src/Fluss/UnitOfWork/IWriteUnitOfWork.cs index 8b069eb..bfbf4a5 100644 --- a/src/Fluss/UnitOfWork/IWriteUnitOfWork.cs +++ b/src/Fluss/UnitOfWork/IWriteUnitOfWork.cs @@ -8,5 +8,8 @@ public interface IWriteUnitOfWork : IUnitOfWork ValueTask GetAggregate(TKey key) where TAggregate : AggregateRoot, new(); + ValueTask GetAggregate() + where TAggregate : AggregateRoot, new(); + ValueTask Publish(Event @event, AggregateRoot? aggregate = null); }