Skip to content

Commit

Permalink
Code refactor for async method
Browse files Browse the repository at this point in the history
  • Loading branch information
aakkem committed Apr 18, 2023
1 parent 94487bd commit 0d30418
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions aws/kinesis/core/test/shard_map_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ void pop(const std::list<T>* q) {

class MockKinesisClient : public Aws::Kinesis::KinesisClient {
public:
MockKinesisClient(
MockKinesisClient (
std::list<Aws::Kinesis::Model::ListShardsOutcome> outcomes_list_shards,
std::function<void ()> callback_list_shards = []{})
: Aws::Kinesis::KinesisClient(kEmptyCreds, fake_client_cfg()),
Expand All @@ -56,7 +56,7 @@ class MockKinesisClient : public Aws::Kinesis::KinesisClient {
const Aws::Kinesis::Model::ListShardsRequest& request,
const Aws::Kinesis::ListShardsResponseReceivedHandler& handler,
const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context
= nullptr) const override {
= nullptr) const {
executor_->schedule([=] {

if (outcomes_list_shards_.size() == 0) {
Expand Down

0 comments on commit 0d30418

Please sign in to comment.