| 542 | } |
| 543 | |
| 544 | static void DoStop(TCont* cont, void* argPtr) { |
| 545 | TState& state = *(TState*)(argPtr); |
| 546 | |
| 547 | TTimerEvent event(cont, TInstant::Now()); |
| 548 | ExecuteEvent(&event); |
| 549 | state.Stop = true; |
| 550 | for (auto& sub: state.Subs) { |
| 551 | if (sub.Event) { |
| 552 | sub.Event->Wake(EWAKEDUP); |
| 553 | } |
| 554 | } |
| 555 | } |
| 556 | |
| 557 | static void DoSub(TCont* cont, void* argPtr) { |
| 558 | TSubState& state = *(TSubState*)(argPtr); |
nothing calls this directly
no test coverage detected