Method pushShardResponses

cpp/registry/BlockServiceFileTracker.cpp:28–30

}

void BlockServiceFileTracker::pushShardResponses(std::vector<ShardResponse>& responses) {
    _queue.push(responses);
}

void BlockServiceFileTracker::_processResponses() {
    _queue.pull(_responses, MAX_SHARD_RESPONSES, 100_ms);