thenixan

service.loadDataWithNewTypeConverter()
                .flatMapObservable {
                    it.data
                }
                .count()
                .subscribe({ result ->
                    println("Size is: $result")
                }, { error -> error.printStackTrace() })

thenixan

data class NewDataHolder(
        @JsonAdapter(ObservableTypeAdapterFactory::class)
        @SerializedName("data")
        val data: Observable<DataItem>
)

class ObservableTypeAdapterFactory : TypeAdapterFactory {

thenixan

class JsonReaderObservable<T>(elementType: Type, gson: Gson, private val reader: JsonReader) : Observable<T>() {

    private val subject = ReplaySubject.create<T>()

    init {
        reader.beginArray()
        while (reader.hasNext()) {
            subject.onNext(gson.fromJson(reader, elementType))
        }
        reader.endArray()

thenixan

        service.loadDataWithoutAnyParsingAtAll()
                .flatMapObservable { responseBody ->
                    Observable.create<DataItem> { emitter ->
                        JsonReader(responseBody.charStream())
                                .use { reader ->
                                    while (reader.hasNext()) {
                                        if (reader.peek() == JsonToken.BEGIN_OBJECT) {
                                            reader.beginObject()
                                            if (reader.nextName() == "data") {

thenixan

// Acquire a reference to the system Location Manager
LocationManager locationManager = (LocationManager) this.getSystemService(Context.LOCATION_SERVICE);

// Define a listener that responds to location updates
LocationListener locationListener = new LocationListener() {
    public void onLocationChanged(Location location) {
      // Called when a new location is found by the network location provider.
      makeUseOfNewLocation(location);
    }

thenixan

import java.io.File


fun main(args: Array<String>) {
    val result = DayOneTask.run()
    println(result)
}


object DayOneTask {