tyler/Libation
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Tweak episode scan

Browse Source
This commit is contained in:
MBucari 2023-03-07 20:32:50 -07:00
parent 3ebd4ce243
commit d3607583ab
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
Source/AudibleUtilities/ApiExtended.cs
View File

@ -97,7 +97,7 @@ namespace AudibleUtilities
var sw = Stopwatch.StartNew(); var sw = Stopwatch.StartNew();
//Scan the library for all added books, and add ay episode-type items to seriesItems to be scanned for episodes/parents //Scan the library for all added books, and add any episode-type items to seriesItems to be scanned for episodes/parents
await foreach (var item in Api.GetLibraryItemAsyncEnumerable(libraryOptions, BatchSize, MaxConcurrency)) await foreach (var item in Api.GetLibraryItemAsyncEnumerable(libraryOptions, BatchSize, MaxConcurrency))
{ {
if ((item.IsEpisodes || item.IsSeriesParent) && importEpisodes) if ((item.IsEpisodes || item.IsSeriesParent) && importEpisodes)
@ -124,8 +124,8 @@ namespace AudibleUtilities
//This method blocks until episodeChannel.Writer is closed by scanAllSeries() //This method blocks until episodeChannel.Writer is closed by scanAllSeries()
await foreach (var ep in getAllEpisodesAsync(episodeChannel.Reader)) await foreach (var ep in getAllEpisodesAsync(episodeChannel.Reader))
{ {
items.Add(ep); items.AddRange(ep);
count++; count += ep.Count;
} }
//Be sure to await the scanAllSeries Task so that any exceptions are thrown //Be sure to await the scanAllSeries Task so that any exceptions are thrown
@ -172,7 +172,7 @@ namespace AudibleUtilities
/// the Items are yielded, that task is removed from the list, and a new get task is read from /// the Items are yielded, that task is removed from the list, and a new get task is read from
/// the channel. /// the channel.
/// </summary> /// </summary>
private async IAsyncEnumerable<Item> getAllEpisodesAsync(ChannelReader<Task<List<Item>>> channel) private async IAsyncEnumerable<List<Item>> getAllEpisodesAsync(ChannelReader<Task<List<Item>>> channel)
{ {
List<Task<List<Item>>> concurentGets = new(); List<Task<List<Item>>> concurentGets = new();
@ -187,8 +187,7 @@ namespace AudibleUtilities
if (await channel.WaitToReadAsync()) if (await channel.WaitToReadAsync())
concurentGets.Add(await channel.ReadAsync()); concurentGets.Add(await channel.ReadAsync());
foreach (var item in completed.Result) yield return completed.Result;
yield return item;
} }
} }