/// Initializes a new instance of the class.
@@ -83,7 +96,10 @@ protected Provider(IJobManager jobManager, IAsyncDelayer asyncDelayer, ILogger();
+ if (chatBot.Instance == null)
+ throw new ArgumentException("chatBot must have Instance!", nameof(chatBot));
+
+ messageQueue = new Queue();
nextMessage = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
initialConnectionTcs = new TaskCompletionSource();
reconnectTaskLock = new object();
@@ -144,7 +160,7 @@ public async ValueTask
- public async Task NextMessage(CancellationToken cancellationToken)
+ public async Task NextMessage(CancellationToken cancellationToken)
{
while (true)
{
@@ -178,15 +194,15 @@ public Task SetReconnectInterval(uint reconnectInterval, bool connectNow)
}
///
- public abstract ValueTask SendMessage(Message replyTo, MessageContent message, ulong channelId, CancellationToken cancellationToken);
+ public abstract ValueTask SendMessage(Message? replyTo, MessageContent message, ulong channelId, CancellationToken cancellationToken);
///
- public abstract ValueTask>>> SendUpdateMessage(
+ public abstract ValueTask>>> SendUpdateMessage(
RevisionInformation revisionInformation,
- Version byondVersion,
+ Api.Models.EngineVersion engineVersion,
DateTimeOffset? estimatedCompletionTime,
- string gitHubOwner,
- string gitHubRepo,
+ string? gitHubOwner,
+ string? gitHubRepo,
ulong channelId,
bool localCommitPushed,
CancellationToken cancellationToken);
@@ -219,7 +235,7 @@ protected abstract ValueTask for .
///
///