private void testServerJoinLate ( Member . Type type , CopycatServer . State state ) throws Throwable { createServers ( 3 ) ; CopycatClient client = createClient ( ) ; submit ( client , 0 , 1000 ) ; await ( 30000 ) ; CopycatServer joiner = createServer ( nextMember ( type ) ) ; joiner . onStateChange ( null ) ; joiner . join ( members . stream ( ) . map ( null ) . collect ( Collectors . toList ( ) ) ) . thenRun ( null ) ; await ( 30000 , 2 ) ; }
Tests joining a server after many entries have been committed .