java

		Observable.just(1, 2, 3, 4, 5)//
				.map(c -> {
					System.out.println("1 " + Thread.currentThread().getName());
					return c;
				})//
				.flatMap(a -> {

					return Observable.just(1) //
							.observeOn(Schedulers.io())//
							.map(b -> b)//
							.map(c -> {
								try
								{
									Thread.sleep(10000);
								}
								catch (InterruptedException e)
								{
									e.printStackTrace();
								}
								System.out.println("2 " + Thread.currentThread().getName());
								return c;
							});
				},1)//
				.map(c -> {
					System.out.println("3 " + Thread.currentThread().getName());
					return c;
				}) //
				.subscribe();


		while (true)
		{
		}