au.gov.amsa.streams

Class Strings

java.lang.Object

au.gov.amsa.streams.Strings

public final class Strings
extends Object

Utilities for stream processing of lines of text from

• sockets

Field Summary

Fields

Modifier and Type	Field and Description
static Charset	DEFAULT_CHARSET
static rx.functions.Func1<Object,String>	TRIM Returns null if input is null otherwise returns input.toString().trim().

Constructor Summary

Constructors

Constructor and Description
Strings()

Method Summary

Modifier and Type	Method and Description
static rx.Observable<String>	from(File file)
static rx.Observable<String>	from(File file, Charset charset)
static rx.Observable<String>	from(Reader reader)
static rx.Observable<String>	from(Reader reader, int size)
static rx.Observable<String>	lines(File file)
static rx.Observable<String>	lines(Reader reader)
static rx.Observable<String>	split(rx.Observable<String> o, int maxItemLength, String pattern, int maxPatternLength)
static rx.Observable<String>	split(rx.Observable<String> o, String pattern)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CHARSET

public static final Charset DEFAULT_CHARSET

TRIM

public static rx.functions.Func1<Object,String> TRIM

Returns null if input is null otherwise returns input.toString().trim().

Constructor Detail

Strings

public Strings()

Method Detail

from

public static rx.Observable<String> from(Reader reader,
                                         int size)

from

public static rx.Observable<String> from(Reader reader)

lines

public static rx.Observable<String> lines(Reader reader)

lines

public static rx.Observable<String> lines(File file)

from

public static rx.Observable<String> from(File file)

split

public static rx.Observable<String> split(rx.Observable<String> o,
                                          String pattern)

split

public static rx.Observable<String> split(rx.Observable<String> o,
                                          int maxItemLength,
                                          String pattern,
                                          int maxPatternLength)

from

public static rx.Observable<String> from(File file,
                                         Charset charset)