Skip to content

Commit

Permalink
All Future helpers should be method calls, not functions
Browse files Browse the repository at this point in the history
  • Loading branch information
tom-binary committed Oct 5, 2022
1 parent f40c887 commit ba0f4f6
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion lib/Myriad/RPC/Implementation/Memory.pm
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ async method start () {
my $messages = await $transport->read_from_stream_by_consumer($rpc->{stream}, $self->group_name, hostname());
await $self->process_stream_messages(rpc => $rpc, messages => $messages) if %$messages;
}), foreach => [ $self->rpc_list->@* ], concurrent => scalar $self->rpc_list->@*);
await Future::wait_any($should_shutdown, $self->loop->delay_future(after => 0.1));
await Future->wait_any($should_shutdown, $self->loop->delay_future(after => 0.1));
}
}

Expand Down

0 comments on commit ba0f4f6

Please sign in to comment.