mirror of
https://github.com/microsoft/autogen.git
synced 2025-07-04 15:41:15 +00:00
b05878aa4a
<img width="1840" alt="Screenshot 2025-01-30 at 6 26 02 PM" src="https://github.com/user-attachments/assets/5b4c9ebf-0880-4b2e-aa1f-f2b956922b49" />
37 lines
1.1 KiB
C#
37 lines
1.1 KiB
C#
// Copyright (c) Microsoft Corporation. All rights reserved.
|
|
// Checker.cs
|
|
|
|
#region snippet_Checker
|
|
using Microsoft.AutoGen.Contracts;
|
|
using Microsoft.AutoGen.Core;
|
|
using Microsoft.Extensions.Hosting;
|
|
using TerminationF = System.Func<int, bool>;
|
|
|
|
namespace GettingStartedSample;
|
|
|
|
[TypeSubscription("default")]
|
|
public class Checker(
|
|
AgentId id,
|
|
IAgentRuntime runtime,
|
|
IHostApplicationLifetime hostApplicationLifetime,
|
|
TerminationF runUntilFunc
|
|
) :
|
|
BaseAgent(id, runtime, "Modifier", null),
|
|
IHandle<CountUpdate>
|
|
{
|
|
public async ValueTask HandleAsync(CountUpdate item, MessageContext messageContext)
|
|
{
|
|
if (!runUntilFunc(item.NewCount))
|
|
{
|
|
Console.WriteLine($"\nChecker:\n{item.NewCount} passed the check, continue.");
|
|
await this.PublishMessageAsync(new CountMessage { Content = item.NewCount }, new TopicId("default"));
|
|
}
|
|
else
|
|
{
|
|
Console.WriteLine($"\nChecker:\n{item.NewCount} failed the check, stopping.");
|
|
hostApplicationLifetime.StopApplication();
|
|
}
|
|
}
|
|
}
|
|
#endregion snippet_Checker
|