We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0544c72 commit 0035e94Copy full SHA for 0035e94
1 file changed
Turbo.Players/Grains/MessengerGrain.cs
@@ -43,13 +43,12 @@ ILogger<IMessengerGrain> logger
43
44
// Batched delivered-flag queue — flushed periodically to avoid per-message DB writes
45
private readonly HashSet<int> _pendingDeliveredIds = [];
46
- private IDisposable? _deliveredFlushTimer;
47
48
public override async Task OnActivateAsync(CancellationToken ct)
49
{
50
_playerId = PlayerId.Parse((int)this.GetPrimaryKeyLong());
51
52
- _deliveredFlushTimer = this.RegisterGrainTimer<object?>(
+ this.RegisterGrainTimer<object?>(
53
static async (self, ct) =>
54
await ((MessengerGrain)self!).FlushDeliveredMessagesAsync(ct),
55
this,
0 commit comments