docs: protected static HashMap<String, String> createInitialSubscribedStreamsToLastDiscoveredShardsState(List<String> streams) {
  		HashMap<String, String> initial = new HashMap<>();
  		for (String stream : streams) {
  			initial.put(stream, null);
  		}
  		return initial;
  	}