()
| 935 | sendStream(ctx, out, event) |
| 936 | } |
| 937 | for _, progress := range executor.DrainProgress() { |
| 938 | sendStream(ctx, out, BuildProgressEvent(progress)) |
| 939 | } |
| 940 | toolResults = append(toolResults, executor.GetCompletedResults()...) |
| 941 | if executor.HasPendingWork() { |
| 942 | executor.WaitForActivity(ctx) |
| 943 | if executor.HasPendingWork() && !executor.HasRunningWork() { |
| 944 | break |
| 945 | } |
| 946 | } |
| 947 | } |
| 948 | for _, event := range e.drainSkillPermissionEvents() { |
| 949 | sendStream(ctx, out, event) |
no outgoing calls
no test coverage detected