epb-644

	public static <T> Observable<SelectEvent> fromWorldWindSelectEvents(final WorldWindow wwd, final Observable<T> disposeObservable){
		return Observable.create(new OnSubscribe<SelectEvent>() {
			@Override
			public void call(final Subscriber<? super SelectEvent> subscriber) {
				final SelectListener listener = new SelectListener() {
					@Override
					public void selected(SelectEvent event) {
						subscriber.onNext(event);
					}
				};

epb-644

public class WorldWindowRx {

    private final WorldWindow worldWindow;
    private final Observable<PositionEvent> mousePositions;

    public WorldWindowRx(WorldWindow worldWindow){
        this.worldWindow = worldWindow;

        this.mousePositions = createMousePositionObservable(); 
    }

epb-644

public class WorldWindowRx {
 
    private final WorldWindow worldWindow;
    private final Observable<PositionEvent> mousePositions;
 
    public WorldWindowRx(WorldWindow worldWindow){
        this.worldWindow = worldWindow;
 
        this.mousePositions = createMousePositionObservable(); 
    }

epb-644

import rx.Observable;
import rx.observables.ConnectableObservable;

public class RxFizzBuzz {
    public static void main(String[] args) {
        final ConnectableObservable<Integer> range = Observable.range(1, 100).publish();

        final Observable<String> out = Observable.merge(
                range.filter((n) -> n % 15 == 0).map((n) -> "FIZZBUZZ"),
                range.filter((n) -> n % 15 != 0 && n % 3 == 0).map((n) -> "FIZZ"),