Function NewTaskEventSink

ui/runtime.go:93–95

()

	queue    chan TaskUiEvent
	mu       sync.RWMutex
	observer func(agent.TaskUIEvent)
}

func NewTaskEventSink() *TaskEventSink {
	return &TaskEventSink{queue: make(chan TaskUiEvent, 128)}
}