com.github.davidmoten.rx

Class Strings

java.lang.Object

com.github.davidmoten.rx.Strings

public final class Strings
extends Object

Constructor Summary

Constructors

Constructor and Description
Strings()

Method Summary

Modifier and Type	Method and Description
static rx.Observable<String>	concat(rx.Observable<String> source)
static rx.Observable<String>	concat(rx.Observable<String> source, String delimiter)
static rx.Observable<String>	decode(rx.Observable<byte[]> source, Charset charset)
static rx.Observable<String>	decode(rx.Observable<byte[]> source, CharsetDecoder decoder)
static rx.Observable<String>	decode(rx.Observable<byte[]> source, String charset)
static rx.Observable<String>	from(File file)
static rx.Observable<String>	from(File file, Charset charset)
static rx.Observable<String>	from(rx.functions.Func0<Reader> readerFactory)
static rx.Observable<String>	from(InputStream is)
static rx.Observable<String>	from(InputStream is, Charset charset)
static rx.Observable<String>	from(InputStream is, Charset charset, int bufferSize)
static rx.Observable<String>	from(Reader reader)
static rx.Observable<String>	from(Reader reader, int bufferSize)
static rx.Observable<String>	fromClasspath(String resource)
static rx.Observable<String>	fromClasspath(String resource, Charset charset)
static rx.Observable<String>	join(rx.Observable<String> source)
static rx.Observable<String>	join(rx.Observable<String> source, String delimiter)
static rx.Observable<String>	split(rx.Observable<String> source, String pattern)
static rx.Observable<List<String>>	splitLines(InputStream is, Charset charset, String delimiter, String commentPrefix)
static rx.Observable<List<String>>	splitLines(InputStream is, String delimiter)
static rx.Observable<String>	strings(rx.Observable<?> source)
static <T> rx.functions.Func1<T,String>	trim()

Methods inherited from class java.lang.Object

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

Constructor Detail

Strings

public Strings()

Method Detail

trim

public static <T> rx.functions.Func1<T,String> trim()

from

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

from

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

from

public static rx.Observable<String> from(InputStream is)

from

public static rx.Observable<String> from(InputStream is,
                                         Charset charset)

from

public static rx.Observable<String> from(InputStream is,
                                         Charset charset,
                                         int bufferSize)

split

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

concat

public static rx.Observable<String> concat(rx.Observable<String> source)

concat

public static rx.Observable<String> concat(rx.Observable<String> source,
                                           String delimiter)

strings

public static rx.Observable<String> strings(rx.Observable<?> source)

from

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

from

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

fromClasspath

public static rx.Observable<String> fromClasspath(String resource,
                                                  Charset charset)

fromClasspath

public static rx.Observable<String> fromClasspath(String resource)

from

public static rx.Observable<String> from(rx.functions.Func0<Reader> readerFactory)

join

public static rx.Observable<String> join(rx.Observable<String> source)

decode

public static rx.Observable<String> decode(rx.Observable<byte[]> source,
                                           CharsetDecoder decoder)

decode

public static rx.Observable<String> decode(rx.Observable<byte[]> source,
                                           Charset charset)

decode

public static rx.Observable<String> decode(rx.Observable<byte[]> source,
                                           String charset)

join

public static rx.Observable<String> join(rx.Observable<String> source,
                                         String delimiter)

splitLines

public static rx.Observable<List<String>> splitLines(InputStream is,
                                                     Charset charset,
                                                     String delimiter,
                                                     String commentPrefix)

splitLines

public static rx.Observable<List<String>> splitLines(InputStream is,
                                                     String delimiter)