com.github.pwittchen.reactivenetwork.library.internet.observing.strategy

Class SocketInternetObservingStrategy

java.lang.Object

com.github.pwittchen.reactivenetwork.library.internet.observing.strategy.SocketInternetObservingStrategy

All Implemented Interfaces:

InternetObservingStrategy

public class SocketInternetObservingStrategy
extends java.lang.Object
implements InternetObservingStrategy

Default strategy for monitoring connectivity with the Internet

Constructor Summary

Constructors

Constructor and Description
SocketInternetObservingStrategy()

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	adjustHost(java.lang.String host)
java.lang.String	getDefaultPingHost() Gets default remote ping host for a given Internet Observing Strategy
protected boolean	isConnected(java.net.Socket socket, java.lang.String host, int port, int timeoutInMs, ErrorHandler errorHandler) checks if device is connected to given host at given port
protected boolean	isConnected(java.lang.String host, int port, int timeoutInMs, ErrorHandler errorHandler) checks if device is connected to given host at given port
<any>	observeInternetConnectivity(int initialIntervalInMs, int intervalInMs, java.lang.String host, int port, int timeoutInMs, ErrorHandler errorHandler) Observes connectivity with the Internet by opening socket connection with remote host

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SocketInternetObservingStrategy

public SocketInternetObservingStrategy()

Method Detail

observeInternetConnectivity

public <any> observeInternetConnectivity(int initialIntervalInMs,
                                         int intervalInMs,
                                         java.lang.String host,
                                         int port,
                                         int timeoutInMs,
                                         ErrorHandler errorHandler)

Observes connectivity with the Internet by opening socket connection with remote host

Specified by:

observeInternetConnectivity in interface InternetObservingStrategy

Parameters:

initialIntervalInMs - in milliseconds determining the delay of the first connectivity check

intervalInMs - in milliseconds determining how often we want to check connectivity

host - for checking Internet connectivity

port - for checking Internet connectivity

timeoutInMs - for pinging remote host in milliseconds

errorHandler - for handling errors while closing socket

Returns:

RxJava Observable with Boolean - true, when we have connection with host and false if not

getDefaultPingHost

public java.lang.String getDefaultPingHost()

Description copied from interface: InternetObservingStrategy

Gets default remote ping host for a given Internet Observing Strategy

Specified by:

getDefaultPingHost in interface InternetObservingStrategy

Returns:

String with a ping host used in the current strategy

adjustHost

protected java.lang.String adjustHost(java.lang.String host)

isConnected

protected boolean isConnected(java.lang.String host,
                              int port,
                              int timeoutInMs,
                              ErrorHandler errorHandler)

checks if device is connected to given host at given port

Parameters:

host - to connect

port - to connect

timeoutInMs - connection timeout

errorHandler - error handler for socket connection

Returns:

boolean true if connected and false if not

isConnected

protected boolean isConnected(java.net.Socket socket,
                              java.lang.String host,
                              int port,
                              int timeoutInMs,
                              ErrorHandler errorHandler)

checks if device is connected to given host at given port

Parameters:

socket - to connect

host - to connect

port - to connect

timeoutInMs - connection timeout

errorHandler - error handler for socket connection

Returns:

boolean true if connected and false if not