Styjun

Does immunity to non magical damage negate sneak attack damage?

How to use multiple criteria for -find

Heuristic argument for the Riemann Hypothesis

Do artifacts count as creatures when they are put into a graveyard while March of the Machines is in play?

Calculus Books, preferably Soviet.

Do index funds really have double-digit percents annual return rates?

How do you manage to study and have a balance in your life at the same time?

What exactly is a softlock?

Solve this icositetragram

How do we know if a dialogue sounds unnatural without asking for feedback?

Why do many programmers abstain from using global variables?

Why not use futuristic pavise ballistic shields for protection?

Punishment in pacifist society

Do we know the problems the University of Manchester's Transistor Computer was intended to solve?

Ideal characterization of almost convergence

Would there be balance issues if I allowed opportunity attacks against any creature, not just hostile ones?

Why didn't Thatcher give Hong Kong to Taiwan?

How did Gollum know Sauron was gathering the Haradrim to make war?

How to check status of Wi-Fi adapter through command line?

How does Harry wear the invisibility cloak?

Lumix G7: Raw photos only in 1920x1440, no higher res available

In chocolate terminology, what is the name of thinly sliced leaf-shaped toppings made from hot, smooth chocolate, used to form flower petals?

Is mathematics truth?

Declaring 2 (or even multi-) dimensional std::arrays elegantly

RxJava2 Flowable's concatMap and concatMapEager with observeOn has different behavior

What is the difference between concatMap and flatMap in RxJavaRxJava flatMapIterable with concatMapObservable.zip chooses different schedulers to subscribe on different callsUnexpected behavior with RxJava2 PublishSubjectRxandroid What's the difference between SubscribeOn and ObserveOnRxJava Chaining Observables with flatmap / concatmap & observeOn threadingRxJava2. Process different properties of the object from the listPlacement of observeOn gives me different behaviorInterrupt a single observable in concatMap

.everyoneloves__top-leaderboard:empty,.everyoneloves__mid-leaderboard:empty,.everyoneloves__bot-mid-leaderboard:empty margin-bottom:0;

0

Should publisher.observerOn(scheduler).concatMap(mapper, 1) and publisher.observerOn(scheduler).concatMapEager(mapper, 1, 1) have same behavior when concatMapEager using concurrency with 1?
I test concatMap and it may use different thread instead of scheduler from observeOn to call the mapper.

for example

Flowable.just(1, 2, 3, 4, 5)
 .observeOn(Schedulers.io())
 .concatMapEager(i -> 
 System.out.println("1>>>>trigger in thread:" + Thread.currentThread());
 return Flowable.create(emitter -> 
 executorService.submit(() -> 
 try 
 Thread.sleep(3000L);
 catch (InterruptedException ignore) 
 
 emitter.onNext("" + i);
 emitter.onComplete();
 );
 , BackpressureStrategy.DROP);
 , 1, 1)
 .map(i -> "ok:" + i)
 .blockingSubscribe();

this prints

1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]

but if change it to concatMap(mapper, 1), it prints

1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-1,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-2,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-3,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-4,5,main]

Should concatMap also use RxCachedThreadScheduler? or it's intentioned.

rx-java rx-java2 concatmap

share|improve this question

edited Apr 14 at 7:26

Filip

5,07733 gold badges1717 silver badges3333 bronze badges

asked Mar 28 at 2:05

koji linkoji lin

30511 gold badge44 silver badges99 bronze badges

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  That doesn't look right with concatMap. Add hide() between observeOn and concatMap to see if that changes things.
  
  – akarnokd
  Mar 28 at 6:04
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  @akarnokd I tried and it's same that using pool-1-thread-x.
  
  – koji lin
  Mar 28 at 7:20
  

  
  
  
  


• 
  
  
  

  
  1
  

  
  
  
  
  
  

  
  
  I see. Please try the other workarounds from this issue.
  
  – akarnokd
  Mar 28 at 8:43
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  And for workaround, I tried to use concatMapEager with concurrency 1 first.
  
  – koji lin
  Mar 29 at 1:01
  

  
  
  
  

add a comment | 

0

Should publisher.observerOn(scheduler).concatMap(mapper, 1) and publisher.observerOn(scheduler).concatMapEager(mapper, 1, 1) have same behavior when concatMapEager using concurrency with 1?
I test concatMap and it may use different thread instead of scheduler from observeOn to call the mapper.

for example

Flowable.just(1, 2, 3, 4, 5)
 .observeOn(Schedulers.io())
 .concatMapEager(i -> 
 System.out.println("1>>>>trigger in thread:" + Thread.currentThread());
 return Flowable.create(emitter -> 
 executorService.submit(() -> 
 try 
 Thread.sleep(3000L);
 catch (InterruptedException ignore) 
 
 emitter.onNext("" + i);
 emitter.onComplete();
 );
 , BackpressureStrategy.DROP);
 , 1, 1)
 .map(i -> "ok:" + i)
 .blockingSubscribe();

this prints

1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]

but if change it to concatMap(mapper, 1), it prints

1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-1,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-2,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-3,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-4,5,main]

Should concatMap also use RxCachedThreadScheduler? or it's intentioned.

rx-java rx-java2 concatmap

share|improve this question

edited Apr 14 at 7:26

Filip

5,07733 gold badges1717 silver badges3333 bronze badges

asked Mar 28 at 2:05

koji linkoji lin

30511 gold badge44 silver badges99 bronze badges

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  That doesn't look right with concatMap. Add hide() between observeOn and concatMap to see if that changes things.
  
  – akarnokd
  Mar 28 at 6:04
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  @akarnokd I tried and it's same that using pool-1-thread-x.
  
  – koji lin
  Mar 28 at 7:20
  

  
  
  
  


• 
  
  
  

  
  1
  

  
  
  
  
  
  

  
  
  I see. Please try the other workarounds from this issue.
  
  – akarnokd
  Mar 28 at 8:43
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  And for workaround, I tried to use concatMapEager with concurrency 1 first.
  
  – koji lin
  Mar 29 at 1:01
  

  
  
  
  

add a comment | 

Should publisher.observerOn(scheduler).concatMap(mapper, 1) and publisher.observerOn(scheduler).concatMapEager(mapper, 1, 1) have same behavior when concatMapEager using concurrency with 1?
I test concatMap and it may use different thread instead of scheduler from observeOn to call the mapper.

for example

Flowable.just(1, 2, 3, 4, 5)
 .observeOn(Schedulers.io())
 .concatMapEager(i -> 
 System.out.println("1>>>>trigger in thread:" + Thread.currentThread());
 return Flowable.create(emitter -> 
 executorService.submit(() -> 
 try 
 Thread.sleep(3000L);
 catch (InterruptedException ignore) 
 
 emitter.onNext("" + i);
 emitter.onComplete();
 );
 , BackpressureStrategy.DROP);
 , 1, 1)
 .map(i -> "ok:" + i)
 .blockingSubscribe();

this prints

1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]

but if change it to concatMap(mapper, 1), it prints

1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-1,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-2,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-3,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-4,5,main]

Should concatMap also use RxCachedThreadScheduler? or it's intentioned.

rx-java rx-java2 concatmap

share|improve this question

edited Apr 14 at 7:26

Filip

5,07733 gold badges1717 silver badges3333 bronze badges

asked Mar 28 at 2:05

koji linkoji lin

30511 gold badge44 silver badges99 bronze badges

Flowable.just(1, 2, 3, 4, 5)
 .observeOn(Schedulers.io())
 .concatMapEager(i -> 
 System.out.println("1>>>>trigger in thread:" + Thread.currentThread());
 return Flowable.create(emitter -> 
 executorService.submit(() -> 
 try 
 Thread.sleep(3000L);
 catch (InterruptedException ignore) 
 
 emitter.onNext("" + i);
 emitter.onComplete();
 );
 , BackpressureStrategy.DROP);
 , 1, 1)
 .map(i -> "ok:" + i)
 .blockingSubscribe();

1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]

1>>>>trigger in thread:Thread[RxCachedThreadScheduler-1,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-1,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-2,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-3,5,main]
1>>>>trigger in thread:Thread[pool-1-thread-4,5,main]

share|improve this question

edited Apr 14 at 7:26

Filip

5,07733 gold badges1717 silver badges3333 bronze badges

asked Mar 28 at 2:05

koji linkoji lin

30511 gold badge44 silver badges99 bronze badges

share|improve this question

edited Apr 14 at 7:26

Filip

5,07733 gold badges1717 silver badges3333 bronze badges

asked Mar 28 at 2:05

koji linkoji lin

30511 gold badge44 silver badges99 bronze badges

edited Apr 14 at 7:26

Filip

5,07733 gold badges1717 silver badges3333 bronze badges

edited Apr 14 at 7:26

Filip

5,07733 gold badges1717 silver badges3333 bronze badges

asked Mar 28 at 2:05

koji linkoji lin

30511 gold badge44 silver badges99 bronze badges

asked Mar 28 at 2:05

koji linkoji lin

30511 gold badge44 silver badges99 bronze badges