|
|
@ -290,14 +290,15 @@ namespace Squidex.Infrastructure.CQRS.Events.Actors |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
private async Task UnsubscribeThisAsync() |
|
|
private Task UnsubscribeThisAsync() |
|
|
{ |
|
|
{ |
|
|
if (eventSubscription != null) |
|
|
if (eventSubscription != null) |
|
|
{ |
|
|
{ |
|
|
await eventSubscription.StopAsync(); |
|
|
eventSubscription.StopAsync().Forget(); |
|
|
|
|
|
|
|
|
eventSubscription = null; |
|
|
eventSubscription = null; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
return TaskHelper.Done; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
private Task SubscribeThisAsync(string position) |
|
|
private Task SubscribeThisAsync(string position) |
|
|
|