| line |
true |
false |
branch |
|
155
|
0 |
0 |
if ($self->_has_last_resume_token) { } |
|
|
0 |
0 |
elsif ($self->_has_start_after) { } |
|
|
0 |
0 |
elsif ($self->_has_last_operation_time) { } |
|
169
|
0 |
0 |
if $self->_has_start_at_operation_time |
|
171
|
0 |
0 |
if ($self->_has_resume_after) |
|
191
|
0 |
0 |
$self->_has_full_document ? : |
|
|
0 |
0 |
$self->_has_max_await_time_ms ? : |
|
197
|
0 |
0 |
if exists $res->{'operationTime'} |
|
226
|
0 |
0 |
if eval {
do {
$change = $self->_result->next;
1
}
} or do {
my $error = $@ || 'Unknown error';
if (not $retried and $error->$MongoDB::ChangeStream::_isa('MongoDB::Error') and $error->_is_resumable) {
$retried = 1;
$self->_execute_query;
}
else {
die $error;
} ;
0
} |
|
228
|
0 |
0 |
if (not $retried and $error->$MongoDB::ChangeStream::_isa('MongoDB::Error') and $error->_is_resumable) { } |
|
245
|
0 |
0 |
unless (defined $change) |
|
249
|
0 |
0 |
if (exists $change->{'postBatchResumeToken'}) { } |
|
|
0 |
0 |
elsif (exists $change->{'_id'}) { } |