mapToObj 会返字符串 “message 1”
IntStream.range(0, 11).mapToObj(i -> "message " + i).peek(message -> publisher.submit(message)).forEach(System.out::println);