Oda/managing-apps
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update running time exec

Browse Source
This commit is contained in:
cryptooda
2025-09-14 23:02:42 +07:00
parent c60bc4123a
commit 37d57a1bb8
8 changed files with 47 additions and 59 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/Managing.Application/Grains/CandleStoreGrain.cs
View File

@@ -77,7 +77,7 @@ public class CandleStoreGrain : Grain, ICandleStoreGrain, IAsyncObserver<Candle>
await base.OnDeactivateAsync(reason, cancellationToken);
}
public Task<List<Candle>> GetCandlesAsync()
public Task<HashSet<Candle>> GetCandlesAsync()
{
try
{
@@ -86,15 +86,15 @@ public class CandleStoreGrain : Grain, ICandleStoreGrain, IAsyncObserver<Candle>
{
_logger.LogWarning("State not initialized for grain {GrainKey}, returning empty list",
this.GetPrimaryKeyString());
return Task.FromResult(new List<Candle>());
return Task.FromResult(new HashSet<Candle>());
}
return Task.FromResult(_state.State.Candles.ToList());
return Task.FromResult(_state.State.Candles.ToHashSet());
}
catch (Exception ex)
{
_logger.LogError(ex, "Error retrieving candles for grain {GrainKey}", this.GetPrimaryKeyString());
return Task.FromResult(new List<Candle>());
return Task.FromResult(new HashSet<Candle>());
}
}
@@ -205,7 +205,7 @@ public class CandleStoreGrain : Grain, ICandleStoreGrain, IAsyncObserver<Candle>
{
try
{
var streamProvider = this.GetStreamProvider("DefaultStreamProvider");
var streamProvider = this.GetStreamProvider("ManagingStreamProvider");
_priceStream = streamProvider.GetStream<Candle>(streamKey);
_streamSubscription = await _priceStream.SubscribeAsync(this);

4
src/Managing.Application/Grains/PriceFetcherGrain.cs
View File

@@ -171,8 +171,8 @@ public class PriceFetcherGrain : Grain, IPriceFetcherGrain, IRemindable
processedCandles.Count, streamKey);
}
var streamProvider = this.GetStreamProvider("DefaultStreamProvider");
var stream = streamProvider.GetStream<Candle>(streamKey);
var streamProvider = this.GetStreamProvider("ManagingStreamProvider");
var stream = streamProvider.GetStream<Candle>("Candles", streamKey);
// Publish to stream (if needed)
foreach (var candle in processedCandles)