Observable.create<String> { observer->
            println("first block thread = ${Thread.currentThread().name}")
            observer.onNext("tu jakas funkcja")
        }.observeOn(Schedulers.io()).subscribeBy {value->
            println("second block thred = ${Thread.currentThread().name} value = $value")
        }