| Package | Description | 
|---|---|
| au.gov.amsa.streams | 
| Modifier and Type | Method and Description | 
|---|---|
static HostPort | 
HostPort.create(String host,
      int port,
      long quietTimeoutMs,
      long reconnectDelayMs)  | 
| Modifier and Type | Method and Description | 
|---|---|
static rx.Observable<String> | 
StringSockets.mergeLinesFrom(rx.Observable<HostPort> hostPorts)  | 
static rx.Observable<String> | 
StringSockets.mergeLinesFrom(rx.Observable<HostPort> hostPorts,
              int maxLineLength)  | 
static rx.Observable<String> | 
StringSockets.mergeLinesFrom(rx.Observable<HostPort> hostPorts,
              rx.Scheduler scheduler)  | 
static rx.Observable<String> | 
StringSockets.mergeLinesFrom(rx.Observable<HostPort> hostPorts,
              rx.Scheduler scheduler,
              int maxLineLength)  | 
Copyright © 2020. All rights reserved.