import io.reactivex.rxjava3.core.Observable;

import io.reactivex.rxjava3.core.Observer;

import io.reactivex.rxjava3.disposables.Disposable;

public class Ch2_07 {

public static void main(String[] args) {

Observable<String> source =

Observable.just("Alpha", "Beta", "Gamma");

Observer<Integer> myObserver = new Observer<Integer>() {

@Override

public void onSubscribe(Disposable d) {

//do nothing with Disposable, disregard for now

}

@Override

public void onNext(Integer value) {

System.out.println("RECEIVED: " + value);

}

@Override

public void onError(Throwable e) {

e.printStackTrace();

}

@Override

public void onComplete() {

System.out.println("Done!");

}

};

source.map(String::length).filter(i -> i >= 5)

.subscribe(myObserver);

}

}