, wenn ich eine andere schduler subscribeon, gratis anmelden nicht mehr funktioniert

Question

* Der folgende Code hat nichts drucken, mich verwirrt * wenn ich subscribeon entfernen, es funktioniert, drucken, was ich will

Observable observable = Observable.<String>create(subscriber -> { 
       try { 
        subscriber.onNext("1"); 
        System.out.println(" current thread is " + Thread.currentThread().getName()); 
        Thread.sleep(100); 
        subscriber.onNext("2"); 
        Thread.sleep(300); 
        subscriber.onNext("3"); 
        Thread.sleep(1000); 
        subscriber.onNext("4"); 
       } catch (Exception e) { 
        e.printStackTrace(); 
       } 
      } 
    ); 

    observable.subscribeOn(Schedulers.io()).timeInterval().observeOn(Schedulers.immediate()).subscribe(n -> System.out.println(((TimeInterval) n).getIntervalInMilliseconds() 
        + " value is " + ((TimeInterval) n).getValue()), 
      e -> System.out.println("onerror " + e), 
      () -> System.out.println("oncomplete ")); 

Answer 1

Ihr Haupt-Thread wird beendet, bevor die subscribeOn wirksam wird, versuchen Sie, auch im Haupt-Thread zu schlafen, oder verwenden Sie toBlocking().subscribe(...). Beachten Sie auch, dass Schedulers.immediate() Aufgaben auf dem gleichen Thread ausführt, auf dem der Wert empfangen wird, und nicht auf dem Thread, der die Sequenz zusammengestellt hat.