vamsitallapudi

2019-01-19 10:20:28.731 1569-1596/com.coderefer.rxandroidexamples D/IntervalOperator: 0
2019-01-19 10:20:29.727 1569-1596/com.coderefer.rxandroidexamples D/IntervalOperator: 1
2019-01-19 10:20:30.728 1569-1596/com.coderefer.rxandroidexamples D/IntervalOperator: 2
2019-01-19 10:20:31.729 1569-1596/com.coderefer.rxandroidexamples D/IntervalOperator: 3
2019-01-19 10:20:32.728 1569-1596/com.coderefer.rxandroidexamples D/IntervalOperator: 4
2019-01-19 10:20:33.728 1569-1596/com.coderefer.rxandroidexamples D/IntervalOperator: 5
2019-01-19 10:20:34.727 1569-1596/com.coderefer.rxandroidexamples D/IntervalOperator: 6
2019-01-19 10:20:35.728 1569-1596/com.coderefer.rxandroidexamples D/IntervalOperator: 7
2019-01-19 10:20:36.727 1569-1596/com.coderefer.rxandroidexamples D/IntervalOperator: 8

vamsitallapudi

package com.coderefer.rxandroidexamples.intro.operators.create

import android.support.v7.app.AppCompatActivity
import android.os.Bundle
import android.util.Log
import com.coderefer.rxandroidexamples.R
import io.reactivex.Observable
import io.reactivex.disposables.Disposable
import java.util.concurrent.TimeUnit

vamsitallapudi

2019-01-18 08:35:48.919 25434-25434/com.coderefer.rxandroidexamples D/FromOperatorActivity: 11
2019-01-18 08:35:48.919 25434-25434/com.coderefer.rxandroidexamples D/FromOperatorActivity: 12
2019-01-18 08:35:48.919 25434-25434/com.coderefer.rxandroidexamples D/FromOperatorActivity: 13
2019-01-18 08:35:48.919 25434-25434/com.coderefer.rxandroidexamples D/FromOperatorActivity: 14
2019-01-18 08:35:48.919 25434-25434/com.coderefer.rxandroidexamples D/FromOperatorActivity: 15

vamsitallapudi

package com.coderefer.rxandroidexamples.intro.operators.create

import android.support.v7.app.AppCompatActivity
import android.os.Bundle
import android.util.Log
import com.coderefer.rxandroidexamples.R
import io.reactivex.Observable
import io.reactivex.disposables.Disposable

private const val TAG = "FromOperatorActivity"

vamsitallapudi

package com.coderefer.rxandroidexamples.intro.operators.create

import android.support.v7.app.AppCompatActivity
import android.os.Bundle
import android.util.Log
import com.coderefer.rxandroidexamples.R
import io.reactivex.Observable
import io.reactivex.disposables.Disposable

private const val TAG = "DeferOperatorActivity"

vamsitallapudi

2019-01-16 07:35:17.108 7865-7865/com.coderefer.rxandroidexamples D/CreateOperatorActivity: 1
2019-01-16 07:35:17.108 7865-7865/com.coderefer.rxandroidexamples D/CreateOperatorActivity: 2
2019-01-16 07:35:17.108 7865-7865/com.coderefer.rxandroidexamples D/CreateOperatorActivity: 3
2019-01-16 07:35:17.108 7865-7865/com.coderefer.rxandroidexamples D/CreateOperatorActivity: 4
2019-01-16 07:35:17.108 7865-7865/com.coderefer.rxandroidexamples D/CreateOperatorActivity: 5
2019-01-16 07:35:17.108 7865-7865/com.coderefer.rxandroidexamples D/CreateOperatorActivity: onComplete

vamsitallapudi

package com.coderefer.rxandroidexamples.intro.operators.create

import android.support.v7.app.AppCompatActivity
import android.os.Bundle
import android.util.Log
import com.coderefer.rxandroidexamples.R
import io.reactivex.Observable
import io.reactivex.Observer
import io.reactivex.disposables.Disposable

vamsitallapudi

package main.algorithms.searching

fun main(args: Array<String>) {
    val input = readLine()!!.trim().split(" ").map { it -> it.toInt() }.toIntArray()    // to read an array (from user input)
    val eleToSearch = readLine()!!.trim().toInt()   // to read the element to be searched (from user input)
    val pos = binarySearchRecursive(input, eleToSearch, 0, input.size -1)
    if(pos >= 0 ) {
        println(pos)    // to print position at last
    } else {
        println("Position not found")

vamsitallapudi

package main.algorithms.searching

fun main(args: Array<String>) {
    val input = readLine()!!.trim().split(" ").map { it -> it.toInt() }.toIntArray()  // to read an array (from user input)
    val eleToSearch = readLine()!!.trim().toInt()   // to read the element to be searched (from user input)
    val pos = binarySearchIterative(input, eleToSearch)
    if(pos >= 0 ) {
        println(pos)    // to print position at last
    } else {
        println("Position not found")

vamsitallapudi

package main.interview.hacklandelection

import com.sun.xml.internal.fastinfoset.util.StringArray
import java.util.*

fun main() {
    val list = StringArray()
    var iter = readLine()!!.toInt()
    while(iter-- > 0) {
        list.add(readLine()!!)