- return ihref.enter_stage<interruptor>(pp(*pg).process, *this
- ).then_interruptible([this, pg, obc, &ihref]() mutable {
- return do_process(ihref, pg, obc);
+ logger().debug("{}: got obc {}", *this, obc->obs);
+ return ihref.enter_stage<interruptor>(
+ client_pp(*pg).process, *this
+ ).then_interruptible([this, pg, obc, &ihref]() mutable {
+ return do_process(ihref, pg, obc);
+ });