docs: @Override
  	public GetShardListResult getShardList(Map<String, String> streamNamesWithLastSeenShardIds) throws InterruptedException {
  		GetShardListResult result = new GetShardListResult();
  
  		for (Map.Entry<String, String> streamNameWithLastSeenShardId : streamNamesWithLastSeenShardIds.entrySet()) {
  			String stream = streamNameWithLastSeenShardId.getKey();
  			String lastSeenShardId = streamNameWithLastSeenShardId.getValue();
  			result.addRetrievedShardsToStream(stream, getShardsOfStream(stream, lastSeenShardId));
  		}
  		return result;
  	}