Creates a shared context between UserContextAggregator and AssistantContextAggregator. Both aggregators read/write through the same Agent, keeping conversation history in sync.
Usage
context = Feline.Context.new([%{role: "system", content: "You are helpful."}])
{:ok, pair} = ContextAggregatorPair.start(context)
pipeline = %Pipeline{
processor_specs: [
{UserContextAggregator, context_agent: pair.agent},
{StreamingLLM, api_key: "..."},
{AssistantContextAggregator, context_agent: pair.agent}
]
}