Skip to content

Commit

Permalink
feat: Overhaul queue implementation
Browse files Browse the repository at this point in the history
  • Loading branch information
@angelobreuer
angelobreuer committed Jul 11, 2023
1 parent f707d40 commit 39f7856
Show file tree
Hide file tree
Showing 13 changed files with 487 additions and 1,797 deletions.
14 changes: 7 additions & 7 deletions src/Lavalink4NET.Tests/Players/QueuedLavalinkPlayerTests.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ public async Task TestPlayerIsStartedOnSkipAsync()
Logger: NullLogger<QueuedLavalinkPlayer>.Instance);

var player = new QueuedLavalinkPlayer(playerProperties);
player.Queue.Enqueue(new TrackQueueItem(new TrackReference("track1")));
await player.Queue.AddAsync(new TrackQueueItem(new TrackReference("track1")));

// Act
await player.SkipAsync().ConfigureAwait(false);
Expand Down Expand Up @@ -146,8 +146,8 @@ public async Task TestPlayerStartsSecondTrackIfNoneIsPlayingButCountIsTwoOnSkipA
Logger: NullLogger<QueuedLavalinkPlayer>.Instance);

var player = new QueuedLavalinkPlayer(playerProperties);
player.Queue.Enqueue(new TrackQueueItem(new TrackReference("track1")));
player.Queue.Enqueue(new TrackQueueItem(new TrackReference("track2")));
await player.Queue.AddAsync(new TrackQueueItem(new TrackReference("track1")));
await player.Queue.AddAsync(new TrackQueueItem(new TrackReference("track2")));

// Act
await player.SkipAsync(count: 2).ConfigureAwait(false);
Expand Down Expand Up @@ -214,7 +214,7 @@ public async Task TestPlayerStopsOnSkipIfQueueIsEmptyAsync()
Logger: NullLogger<QueuedLavalinkPlayer>.Instance);

var player = new QueuedLavalinkPlayer(playerProperties);
player.Queue.Enqueue(new TrackQueueItem(new TrackReference("track1")));
await player.Queue.AddAsync(new TrackQueueItem(new TrackReference("track1")));

// Act
await player.SkipAsync(count: 2).ConfigureAwait(false);
Expand Down Expand Up @@ -284,7 +284,7 @@ public async Task TestPlayerPlaysNextAfterTrackEndAsync()
Logger: NullLogger<QueuedLavalinkPlayer>.Instance);

var player = new QueuedLavalinkPlayer(playerProperties);
player.Queue.Enqueue(new TrackQueueItem(new TrackReference("track2")));
await player.Queue.AddAsync(new TrackQueueItem(new TrackReference("track2")));

var listener = (ILavalinkPlayerListener)player;

Expand Down Expand Up @@ -361,7 +361,7 @@ public async Task TestPlayerRepeatsTrackIfRepeatModeIsTrackAsync()
var player = new QueuedLavalinkPlayer(playerProperties);
player.RepeatMode = TrackRepeatMode.Track;

player.Queue.Enqueue(new TrackQueueItem(new TrackReference("track2")));
await player.Queue.AddAsync(new TrackQueueItem(new TrackReference("track2")));

var listener = (ILavalinkPlayerListener)player;

Expand Down Expand Up @@ -438,7 +438,7 @@ public async Task TestPlayerRepeatsTrackIfRepeatModeIsTrackOnSkipAsync()
var player = new QueuedLavalinkPlayer(playerProperties);
player.RepeatMode = TrackRepeatMode.Track;

player.Queue.Enqueue(new TrackQueueItem(new TrackReference("track2")));
await player.Queue.AddAsync(new TrackQueueItem(new TrackReference("track2")));

// Act
await player
Expand Down
Loading

0 comments on commit 39f7856

Please sign in to comment.