| 18 | namespace bytedance::bolt::exec { |
| 19 | |
| 20 | bool PushBasedEvent::schedule( |
| 21 | const std::shared_ptr<LocalExchangeQueue>& inputQueue, |
| 22 | int partition, |
| 23 | bool isLast) { |
| 24 | if (isLast) { |
| 25 | if (!finish(isLast)) { |
| 26 | return false; |
| 27 | } |
| 28 | } |
| 29 | create_consuming_driver_callback_(inputQueue, partition, isLast); |
| 30 | return true; |
| 31 | } |
| 32 | |
| 33 | bool PushBasedEvent::finish(bool isLast) { |
| 34 | bool expected = false; |
no outgoing calls
no test coverage detected