au.gov.amsa.streams

Class StringSockets

java.lang.Object

au.gov.amsa.streams.StringSockets

public final class StringSockets
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StringSockets.Builder

Constructor Summary

Constructors

Constructor and Description
StringSockets()

Method Summary

Modifier and Type	Method and Description
static rx.Observable<String>	from(rx.functions.Func0<Socket> socketCreator, long quietTimeoutMs, long reconnectDelayMs, Charset charset, rx.Scheduler scheduler)
static StringSockets.Builder	from(String host) Returns a builder for converting a socket read to an Observable.
static rx.Observable<String>	from(String host, int port, long quietTimeoutMs, long reconnectDelayMs, Charset charset, rx.Scheduler scheduler) Returns an Observable sequence of strings (not lines) from the given host and port.
static void	main(String[] args)
static rx.Observable<String>	mergeLinesFrom(rx.Observable<HostPort> hostPorts)
static rx.Observable<String>	mergeLinesFrom(rx.Observable<HostPort> hostPorts, int maxLineLength)
static rx.Observable<String>	mergeLinesFrom(rx.Observable<HostPort> hostPorts, rx.Scheduler scheduler)
static rx.Observable<String>	mergeLinesFrom(rx.Observable<HostPort> hostPorts, rx.Scheduler scheduler, int maxLineLength)
static rx.Observable<String>	strings(rx.functions.Func0<Socket> socketCreator, Charset charset)
static rx.Observable<String>	strings(String host, int port, int quietTimeoutMs, Charset charset)

Methods inherited from class java.lang.Object

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

Constructor Detail

StringSockets

public StringSockets()

Method Detail

from

public static rx.Observable<String> from(String host,
                                         int port,
                                         long quietTimeoutMs,
                                         long reconnectDelayMs,
                                         Charset charset,
                                         rx.Scheduler scheduler)

Returns an Observable sequence of strings (not lines) from the given host and port. If the stream is quiet for quietTimeoutMs then a reconnect will be attempted. Note that this is a good idea with TCPIP connections as for instance a firewall can simply drop a quiet connection without the client being aware of it. If any exception occurs a reconnect will be attempted after reconnectDelayMs. If the socket is closed by the server (the end of the input stream is reached) then a reconnect is attempted after reconnectDelayMs.

Parameters:

hostPort -

Returns:

Observable sequence of strings (not lines).

from

public static rx.Observable<String> from(rx.functions.Func0<Socket> socketCreator,
                                         long quietTimeoutMs,
                                         long reconnectDelayMs,
                                         Charset charset,
                                         rx.Scheduler scheduler)

from

public static StringSockets.Builder from(String host)

Returns a builder for converting a socket read to an Observable. Defaults to port=6564, quietTimeoutMs=60000, reconnectDelayMs=30000, charset= UTF-8.

Parameters:

host -

Returns:

strings

public static rx.Observable<String> strings(String host,
                                            int port,
                                            int quietTimeoutMs,
                                            Charset charset)

strings

public static rx.Observable<String> strings(rx.functions.Func0<Socket> socketCreator,
                                            Charset charset)

mergeLinesFrom

public static rx.Observable<String> mergeLinesFrom(rx.Observable<HostPort> hostPorts,
                                                   rx.Scheduler scheduler)

mergeLinesFrom

public static rx.Observable<String> mergeLinesFrom(rx.Observable<HostPort> hostPorts,
                                                   int maxLineLength)

mergeLinesFrom

public static rx.Observable<String> mergeLinesFrom(rx.Observable<HostPort> hostPorts,
                                                   rx.Scheduler scheduler,
                                                   int maxLineLength)

mergeLinesFrom

public static rx.Observable<String> mergeLinesFrom(rx.Observable<HostPort> hostPorts)

main

public static void main(String[] args)