Method appendSteerAndEmit

pkg/runtime/loop.go:60–63

appendSteerAndEmit adds a steer message to the session and emits the corresponding event.

(sess *session.Session, sm QueuedMessage, events EventSink)

// appendSteerAndEmit adds a steer message to the session and emits the corresponding event.
func (r *LocalRuntime) appendSteerAndEmit(sess *session.Session, sm QueuedMessage, events EventSink) {
	sess.AddMessage(session.UserMessage(sm.Content, sm.MultiContent...))
	events.Emit(UserMessage(sm.Content, sess.ID, sm.MultiContent, len(sess.Messages)-1))
}

// drainAndEmitSteered drains all messages from the steer queue and injects
// them into the session as individual user messages. When multiple messages