Function findStreamingMatch

src/a2a-handler.ts:310–322

(
  text: string,
  agents: Map<string, { def: A2AAgentDefinition; patterns: PatternEntry[] }>,
)

// ---- Streaming helpers ----

export function findStreamingMatch(
  text: string,
  agents: Map<string, { def: A2AAgentDefinition; patterns: PatternEntry[] }>,
): StreamingTaskPatternEntry | null {
  for (const agent of agents.values()) {
    for (const entry of agent.patterns) {
      if (entry.kind === "streamingTask" && matchPattern(text, entry.pattern)) {
        return entry;
      }
    }
  }
  return null;
}

export { extractText };