1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20

@Test
public void DemoSubscriber_test_flux_generate3() {
    final Random random = new Random();
    Flux.generate(ArrayList::new, (list, sink) -> {
        int value = random.nextInt(100);
        list.add(value);
        System.out.println("所发射元素产生的线程: "+Thread.currentThread().getName());
        sink.next(value);
        sleep(2);
        if (list.size() == 6) {
            sink.complete();
        }
        return list;
    })
            .publishOn(Schedulers.elastic(),2)
//                .publishOn(custom_Scheduler(),2)
            .map(x -> String.format("[%s] %s", Thread.currentThread().getName(), x))
            .subscribe(System.out::println);
    sleep(2000);
}