How to iterate through JSONArray Using RXJava 2?

Question

to iterate through array list one can use following code

 List<LatLng> latLngs = new ArrayList<>();
                        latLngs.add(new LatLng(5,5));

                        Observable.just(latLngs)
                                .concatMap(array -> Observable.fromIterable(array))
                                .subscribe(v-> Log.d(TAG, "subscribeToTopic: "+v.latitude));

but how to iterate through JSONarray like this using Rxjava?

 [{
    "vehicleId": "5c11e863a361762fdbe99fae",
    "latitude": "19.952829",
    "latitudeDir": "N",
    "longitude": "73.735054",
    "longitudeDir": "E",
    "speed": "0.0",
    "ignition": "0",
    "batteryStatus": "1"
 }, {
    "vehicleId": "5c11e863a361762fdbe99fae",
    "latitude": "19.952829",
    "latitudeDir": "N",
    "longitude": "73.735054",
    "longitudeDir": "E",
    "speed": "0.0",
    "ignition": "0",
    "batteryStatus": "1"
 }, {
    "vehicleId": "5c11e863a361762fdbe99fae",
    "latitude": "19.952829",
    "latitudeDir": "N",
    "longitude": "73.735054",
    "longitudeDir": "E",
    "speed": "0.0",
    "ignition": "0",
    "batteryStatus": "1"
 }, {
    "vehicleId": "5c11e863a361762fdbe99fae",
    "latitude": "19.952829",
    "latitudeDir": "N",
    "longitude": "73.735054",
    "longitudeDir": "E",
    "speed": "0.0",
    "ignition": "0",
    "batteryStatus": "1"
 }]

why are you iterating a collection with Rx when you could in this case just use a regular for loop — EpicPandaForce
– EpicPandaForce, Commented Dec 19, 2018 at 9:33

taygetos · Accepted Answer · 2018-12-19 13:46:47Z

2

Since JSONArray implements the List interface (assuming that you using simplejson here), you can pretty much do the same:

JSONArray jsonArray = new JSONArray();
Observable.fromIterable(jsonArray)
  .subscribe(e -> {
    System.out.println((JSONObject) e);
  });

EDIT: based on your comments i think you're not using simplejson but this org.json.JSONArray which does not implement the List interface. In this case you can iterate like this:

JSONArray jsonArray = new JSONArray();
Observable.range(0,jsonArray.length())
  .map(jsonArray::get)
  .subscribe(e -> {
     System.out.println((JSONObject) e);
  });

edited Dec 19, 2018 at 13:46

answered Dec 19, 2018 at 10:24

taygetos

3,0502 gold badges23 silver badges30 bronze badges

Sign up to request clarification or add additional context in comments.

2 Comments

akshay_shahane Over a year ago

gives error... i have already tried this. fromIterable (java.lang.Iterable<? extends T>) in Observable cannot be applied to (org.json.JSONArray)

taygetos Over a year ago

i also tried right now, it seems to work for me. Can you share some additional info, what versions are you using from rx and from simplejson. and what is the exact error message?

Collectives™ on Stack Overflow

How to iterate through JSONArray Using RXJava 2?

1 Answer 1

2 Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

2 Comments

Your Answer

Sign up or log in

Post as a guest

Related