Skip to content

Instantly share code, notes, and snippets.

@ptwohig
Created February 22, 2021 19:04
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save ptwohig/2a88108540eb17dd1ad4080b150e09f7 to your computer and use it in GitHub Desktop.
Save ptwohig/2a88108540eb17dd1ad4080b150e09f7 to your computer and use it in GitHub Desktop.
final var local = new SimpleInstanceHostInfo(getInternalBindAddress());
concat(of(local), known.stream())
.filter(nfo -> !getBindAddress().equals(nfo.getConnectAddress()))
.filter(not(nfo -> pending.containsKey(nfo) || active.containsKey(nfo)))
.forEach(nfo -> createNewConnection(nfo)); // Throws class java.lang.String cannot be
// cast to class InstanceHostInfo
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment