返回 DeepSeek-Reasonix
runtime_state_forwarders.go
根目录 / internal / control / runtime_state_forwarders.go
1 package control
2
3 import "reasonix/internal/event"
4
5 func (s *inboxEventSink) RuntimeStateChanged(snapshot event.RuntimeStateSnapshot) {
6 if s != nil {
7 event.PublishRuntimeState(s.inner, snapshot)
8 }
9 }
10 func (s *frontendEventSink) RuntimeStateChanged(snapshot event.RuntimeStateSnapshot) {
11 if s != nil {
12 event.PublishRuntimeState(s.inner, snapshot)
13 }
14 }
15 func (s *turnEventSink) RuntimeStateChanged(snapshot event.RuntimeStateSnapshot) {
16 if s != nil {
17 event.PublishRuntimeState(s.innerSnapshot(), snapshot)
18 }
19 }
20 func (s *turnEventDurableSink) RuntimeStateChanged(snapshot event.RuntimeStateSnapshot) {
21 if s != nil {
22 event.PublishRuntimeState(s.inner(), snapshot)
23 }
24 }
25
25 lines GO