Processing sketch using RXJava

RXTest.pde

import java.util.List;
Observable<String> cities;
Observer<String> traveller;
void setup() {
  List<String> cityList = new ArrayList();
  cityList.add("13");
  cityList.add("12");
  cityList.add("11");
  cityList.add("10");
  cityList.add("9");
  cityList.add("7");

  cities = Observable.from(cityList);

  traveller = new Observer<String>() {

    @Override
      public void onCompleted() {
      System.out.println("My trip is finished");
    }

    @Override
      public void onError(Throwable e) {
      System.out.println("I won't complete my trip!");
    }

    @Override
      public void onNext(String t) {
      println(loadStrings("http://diy.local/arduino/digital/" + t));
    }
  };

  
}

void keyPressed() {
  cities.subscribeOn(Schedulers.computation()).subscribe(traveller);
}

void draw() {
  background(random(0, 255));

}