Method Send

pkg/embeddedchat/embeddedchat.go:224–249

Send appends prompt to the conversation and streams the assistant reply. The returned channel closes when the runtime stream stops. A clean stream emits a final Done event first; a stream that reports an ErrorEvent emits one Err event, suppresses later projected events, then keeps draining until the

(ctx context.Context, prompt string)

// If ctx is cancelled, Send drains the runtime stream until it stops, but no
// further events are delivered to the caller.
func (s *Session) Send(ctx context.Context, prompt string) (<-chan Event, error) {
	s.mu.Lock()
	if s.rt == nil || s.session == nil {
		s.mu.Unlock()
		return nil, ErrNotInitialized
	}
	if s.closed {
		s.mu.Unlock()
		return nil, ErrClosed
	}
	if s.activeCancel != nil {
		s.mu.Unlock()
		return nil, ErrRunActive
	}
	runCtx, cancel := context.WithCancel(ctx)
	s.activeCancel = cancel
	s.activeRun++
	runID := s.activeRun
	s.session.AddMessage(session.UserMessage(prompt))
	events := s.rt.RunStream(runCtx, s.session)
	s.mu.Unlock()

	out := make(chan Event, eventBufferSize(s.cfg.EventBuffer))
	go s.forwardEvents(runCtx, events, out, cancel, runID)
	return out, nil
}

// Confirm answers the pending tool confirmation, if any.
func (s *Session) Confirm(ctx context.Context, req dagentruntime.ResumeRequest) error {