- my $inflight_c = $self->{inflight_c} // check_async_begin($self);
- write_all($self, $self->{out_c}, $oid."\n",
- \&check_async_step, $inflight_c);
- push(@$inflight_c, $oid, $cb, $arg);
+ my $inflight = $self->{-bc} ?
+ ($self->{inflight} // cat_async_begin($self)) :
+ ($self->{inflight_c} // check_async_begin($self));
+ if ($self->{-bc}) {
+ substr($oid, 0, 0) = 'info ';
+ write_all($self, $self->{out}, "$oid\n",
+ \&cat_async_step, $inflight);
+ } else {
+ write_all($self, $self->{out_c}, "$oid\n",
+ \&check_async_step, $inflight);
+ }
+ push(@$inflight, $oid, $cb, $arg);