Class MiddlewareStreamingAgent

Namespace

AutoGen.Core

Assembly

AutoGen.Core.dll

public class MiddlewareStreamingAgent : IMiddlewareStreamAgent, IStreamingAgent, IAgent, IAgentMetaInformation

Inheritance

object

MiddlewareStreamingAgent

Implements

IMiddlewareStreamAgent

IStreamingAgent

IAgent

IAgentMetaInformation

Derived

MiddlewareStreamingAgent<T>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

AgentExtension.InitiateChatAsync(IAgent, IAgent, string?, int, CancellationToken)

AgentExtension.SendAsync(IAgent, IAgent, IEnumerable<IMessage>, int, CancellationToken)

AgentExtension.SendAsync(IAgent, IAgent, string, IEnumerable<IMessage>?, int, CancellationToken)

AgentExtension.SendAsync(IAgent, IMessage?, IEnumerable<IMessage>?, CancellationToken)

AgentExtension.SendAsync(IAgent, string, IEnumerable<IMessage>?, CancellationToken)

AgentExtension.SendMessageToGroupAsync(IAgent, IGroupChat, IEnumerable<IMessage>?, int, CancellationToken)

AgentExtension.SendMessageToGroupAsync(IAgent, IGroupChat, string, IEnumerable<IMessage>?, int, CancellationToken)

GroupChatExtension.AddInitializeMessage(IAgent, string, IGroupChat)

GroupChatExtension.SendIntroduction(IAgent, string, IGroupChat)

AgentExtension.RegisterDotnetCodeBlockExectionHook(IAgent, InteractiveService, string, string, int)

MiddlewareExtension.RegisterMiddleware<TAgent>(TAgent, IMiddleware)

MiddlewareExtension.RegisterMiddleware<TAgent>(TAgent, Func<IEnumerable<IMessage>, GenerateReplyOptions?, IAgent, CancellationToken, Task<IMessage>>, string?)

MiddlewareExtension.RegisterPostProcess<TAgent>(TAgent, Func<IEnumerable<IMessage>, IMessage, CancellationToken, Task<IMessage>>)

MiddlewareExtension.RegisterPreProcess<TAgent>(TAgent, Func<IEnumerable<IMessage>, CancellationToken, Task<IEnumerable<IMessage>>>)

MiddlewareExtension.RegisterReply<TAgent>(TAgent, Func<IEnumerable<IMessage>, CancellationToken, Task<IMessage?>>)

PrintMessageMiddlewareExtension.RegisterPrintFormatMessageHook<TAgent>(TAgent)

PrintMessageMiddlewareExtension.RegisterPrintMessage<TAgent>(TAgent)

StreamingMiddlewareExtension.RegisterStreamingMiddleware<TStreamingAgent>(TStreamingAgent, IStreamingMiddleware)

Constructors

MiddlewareStreamingAgent(IStreamingAgent, string?, IEnumerable<IStreamingMiddleware>?)

public MiddlewareStreamingAgent(IStreamingAgent agent, string? name = null, IEnumerable<IStreamingMiddleware>? streamingMiddlewares = null)

Parameters

agent IStreamingAgent

name string

streamingMiddlewares IEnumerable<IStreamingMiddleware>

Properties

Name

public string Name { get; }

Property Value

string

StreamingAgent

Get the inner agent.

public IStreamingAgent StreamingAgent { get; }

Property Value

IStreamingAgent

StreamingMiddlewares

Get the streaming middlewares.

public IEnumerable<IStreamingMiddleware> StreamingMiddlewares { get; }

Property Value

IEnumerable<IStreamingMiddleware>

Methods

GenerateReplyAsync(IEnumerable<IMessage>, GenerateReplyOptions?, CancellationToken)

Generate reply

public Task<IMessage> GenerateReplyAsync(IEnumerable<IMessage> messages, GenerateReplyOptions? options = null, CancellationToken cancellationToken = default)

Parameters

messages IEnumerable<IMessage>

conversation history

options GenerateReplyOptions

completion option. If provided, it should override existing option if there's any

cancellationToken CancellationToken

Returns

Task<IMessage>

GenerateStreamingReplyAsync(IEnumerable<IMessage>, GenerateReplyOptions?, CancellationToken)

public IAsyncEnumerable<IMessage> GenerateStreamingReplyAsync(IEnumerable<IMessage> messages, GenerateReplyOptions? options = null, CancellationToken cancellationToken = default)

Parameters

messages IEnumerable<IMessage>

options GenerateReplyOptions

cancellationToken CancellationToken

Returns

IAsyncEnumerable<IMessage>

UseStreaming(IStreamingMiddleware)

public void UseStreaming(IStreamingMiddleware middleware)

Parameters

middleware IStreamingMiddleware