反应式编程之flux concatmap

	@Test
	public void concatmap(){
		Student st1 = new Student("张三",90);
		Student st2 = new Student("李四",91);
		Student st3 = new Student("王二",87);
		Student st4 = new Student("李逵",97);
		Student st5 = new Student("宋江",85);
		List<Student> list1 = new ArrayList<>();
		list1.add(st1);
		list1.add(st2);
		list1.add(st5);
		List<Student> list2 = new ArrayList<>();
		list2.add(st3);
		list2.add(st4);
		Teacher t1 = new Teacher();
		t1.setStudents(list1);
		Teacher t2 = new Teacher();
		t2.setStudents(list2);
		List<Teacher> teachers = new ArrayList<>();
		teachers.add(t1);
		teachers.add(t2);
		Flux.fromIterable(teachers).concatMap(t->Flux.fromIterable(t.getStudents()))
		.sort((s1,s2)->s1.getScore()-s2.getScore())
		.subscribe(System.out::println);
	}