KowalczykBartek

    public static void main(String... args) {
        AtomicInteger a = new AtomicInteger();

        Observable.just(1, 2, 3, 4, 5, 6, 7, 8)
                .repeatWhen(notification -> {
                    return notification.flatMap(o -> {

                        System.out.println("'repeatWhen'");
                        if(a.getAndAdd(1) < 10){
                            return Observable.just(o).delay(1,TimeUnit.SECONDS);

KowalczykBartek

Lets consider this simple code snippet :

final EventLoopGroup group = new NioEventLoopGroup(1); 
group.execute(new Runnable()
{
    @Override
    public void run()
    {
        {
            Bootstrap b = new Bootstrap();

KowalczykBartek

photos.flatMap(it -> Observable.from(it))
                .delay(1, TimeUnit.SECONDS)
                .subscribeOn(AndroidSchedulers.mainThread())
    
                .flatMap(it -> {
                    view.pictureUploadProgress(it.getPictureType().name()); //to jest ustawienie widoku że wysyłam it element
                    client.uploadDriverPicture(reservationId, pictureInput) //to jest observable który wykonuje potem zapytanie i zwraca response
                    .subscribeOn(Schedulers.io()) // na tym wątku muszę wykonać zapytanie sieciowe 
                    .observeOn(AndroidSchedulers.main()) //na tym wątku mogę robić update widoku, ale nie chcę tego robić tutaj
                    .doOnNext(response -> {})

KowalczykBartek

		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)//

KowalczykBartek

		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)//

KowalczykBartek

char* adasidaisdu(char **args, int argc)
{
    char* szukaj = "-d";

    int i=1; //omit 0 - due to 0 is application name itself
    for(i = 1; i < argc; i++)
    {

        if(strcmp(decompressionFlag, args[i]) == 0)
        {

KowalczykBartek

int sprawdzanie_argumentow(char** argv,char* argument)
{
   int b = 1;
   while ( b < 8 ){
            if (strcmp(argv[b],argument) == 0){
                printf("ARGV %s\n",argv[b]);
                return 0;

                }
            else{

KowalczykBartek

<output jsf:id="confirm" name="confirm"> 
  Hoho ale to trudne - #{reservationBean.lista[0]}. 
</output>  

KowalczykBartek

...
  ...
    private List<String> lista = new ArrayList<>();
    
    @PostConstruct
    public void init(){
        lista.add("1");
        lista.add("2");
        lista.add("3");
    }

KowalczykBartek

System.out.println("Asdasd");