private void sync ( ) { List < SwimMember > syncMembers = discoveryService . getNodes ( ) . stream ( ) . map ( node -> new SwimMember ( MemberId . from ( node . id ( ) . id ( ) ) , node . address ( ) ) ) . filter ( member -> ! member . id ( ) . equals ( localMember . id ( ) ) ) . collect ( Collectors . toList ( ) ) ; for ( SwimMember member : syncMembers ) { sync ( member . copy ( ) ) ; } }
Synchronizes the node state with peers .