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

Class WalledGardenInternetObservingStrategy

java.lang.Object

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

All Implemented Interfaces:

InternetObservingStrategy

public class WalledGardenInternetObservingStrategy
extends java.lang.Object
implements InternetObservingStrategy

Constructor Summary

Constructors

Constructor and Description
WalledGardenInternetObservingStrategy()

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	adjustHost(java.lang.String host)
protected javax.net.ssl.HttpsURLConnection	createHttpsUrlConnection(java.lang.String host, int port, int timeoutInMs)
protected java.net.HttpURLConnection	createHttpUrlConnection(java.lang.String host, int port, int timeoutInMs)
java.lang.String	getDefaultPingHost() Gets default remote ping host for a given Internet Observing Strategy
protected java.lang.Boolean	isConnected(java.lang.String host, int port, int timeoutInMs, ErrorHandler errorHandler)
<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

WalledGardenInternetObservingStrategy

public WalledGardenInternetObservingStrategy()

Method Detail

observeInternetConnectivity

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

Description copied from interface: InternetObservingStrategy

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 checking connectivity

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 java.lang.Boolean isConnected(java.lang.String host,
                                        int port,
                                        int timeoutInMs,
                                        ErrorHandler errorHandler)

createHttpUrlConnection

protected java.net.HttpURLConnection createHttpUrlConnection(java.lang.String host,
                                                             int port,
                                                             int timeoutInMs)
                                                      throws java.io.IOException

Throws:

java.io.IOException

createHttpsUrlConnection

protected javax.net.ssl.HttpsURLConnection createHttpsUrlConnection(java.lang.String host,
                                                                    int port,
                                                                    int timeoutInMs)
                                                             throws java.io.IOException

Throws:

java.io.IOException