Observable.interval(1, TimeUnit.MILLISECONDS)
				.doFinally(() -> System.err.println("finally obs"))
				.toFlowable(BackpressureStrategy.ERROR)
				.doFinally(() -> System.err.println("finally flow"))
				.observeOn(Schedulers.computation())
				.map(any -> {
					System.out.println("any = " + any);
					Thread.sleep(1000);
					return any;
				})
				.subscribe(any -> {
				}, err -> {
					System.err.println(err.getMessage());
				});