context.java

	Flux<Integer> intFlux = Flux.range(1, 1000)
		                            //2
		                            //old: test=baseSubscriber
		                            //next: test=baseSubscriber_range
		                            .contextualize((old, next) -> next.put("test", old.get("test") + "_range"))
		                            .flatMap(d -> Flux.just(d)
						              //4 (x1000)
		                                              //old: test=baseSubscriber_range
		                                              //next: test=baseSubscriber_range_innerFlatmap
		                                              .contextualize((old, next) -> next.put("test", old.get("test") + "_innerFlatmap")))
		                            .map(d -> d)
		                            .distinct()
		                            //3
		                            //old: test=baseSubscriber_range
		                            //next: test=baseSubscriber_range_distinct
		                            .contextualize((old, next) -> next.put("test", old.get("test") + "_distinct"))
					    .subscribe(new BaseSubscriber<Integer>() {
						//1    
						//old: [empty]
		                                //next: test=baseSubscriber
						@Override
						public Context pullContext() {
							return Context.empty()
								      .put("test", "baseSubscriber");
						} 
					    });