RoboPing

A small library wrapper for calling /system/bin/ping and get the result as RxJava's Completable or Observable<String> classes

Installation:

Add this to your project level build.gradle file:

repositories {
  maven { url "https://jitpack.io" }
}

And then add this to your module level build.gradle:

dependencies {
  implementation 'com.github.sizeofanton:RoboPing:1.0'
}

Usage:

Building an instance:

val pingWrapper = RoboPing.Builder()
	.setCount(10)
	.setInterval(2)
	.build()

All available Builder methods:

Method	Description
enableBroadcast()	Allows pinging a broadcast address
setCount(count: Int)	Set the number of times to send the ping request
enableSoDebug()	Set the SO-DEBUG option on the socket being used
enableFlood()	Flood the network by sending hundred or more packets per second
setInterval(interval: Int)	Specify an interval between successive packet transmissions
setTtl(ttl: Int)	Set the Time To Live (number of hops)
setDeadline(deadline: Int)	Specify a timeout, in seconds, before ping exits
setTimeout(timeout: Int)	Set the time(seconds) to wait for a response
build()	Creates RoboPing class instance with specified parameters

RoboPing contains two methods, one that returns a Completable class without any additional information and the one that returns an Observable<String> with a ping command's stdout and stderr , that will be transmited to observers.

Silent ping example:

val pingWrapper = RoboPing.Builder().build()
pingWrapper.ping(host)
	.subscribeOn(Schedulers.io())
	.observeOn(AndroidSchedulers.mainThread())
	.subscribe({
    Toast.makeText(this, "Host reachable", Toast.LENGTH_LONG).show()
  },{
    Toast.makeText(this, "Host unreachable", Toast.LENGTH_LONG).show()
  })

Verbose ping example:

val pingWrapper = RoboPing.Builder().build()
pingWrapper.ping(host)
	.subscribeOn(Schedulers.io())
	.observeOn(AndroidSchedulers.mainThread())
	.subscribe({
    log.append(it)
  },{
    log.append(errorMsg)
  })