com.github.davidmoten.rx2

Class Strings

java.lang.Object

com.github.davidmoten.rx2.Strings

public final class Strings
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static Charset	UTF_8

Method Summary

Modifier and Type	Method and Description
static io.reactivex.functions.Function<io.reactivex.Flowable<String>,io.reactivex.Maybe<String>>	concat()
static io.reactivex.Maybe<String>	concat(io.reactivex.Flowable<String> source)
static io.reactivex.Maybe<String>	concat(io.reactivex.Flowable<String> source, String delimiter)
static io.reactivex.functions.Function<io.reactivex.Flowable<String>,io.reactivex.Maybe<String>>	concat(String delimiter)
static io.reactivex.FlowableTransformer<byte[],String>	decode(CharsetDecoder decoder)
static io.reactivex.FlowableTransformer<byte[],String>	decode(CharsetDecoder decoder, io.reactivex.BackpressureStrategy backpressureStrategy, int requestBatchSize)
static io.reactivex.Flowable<String>	decode(io.reactivex.Flowable<byte[]> source, Charset charset)
static io.reactivex.Flowable<String>	decode(io.reactivex.Flowable<byte[]> source, CharsetDecoder decoder)
static io.reactivex.Flowable<String>	decode(io.reactivex.Flowable<byte[]> source, String charset)
static io.reactivex.Flowable<String>	from(Callable<Reader> readerFactory)
static io.reactivex.Flowable<String>	from(File file)
static io.reactivex.Flowable<String>	from(File file, Charset charset)
static io.reactivex.Flowable<String>	from(InputStream is)
static io.reactivex.Flowable<String>	from(InputStream is, Charset charset)
static io.reactivex.Flowable<String>	from(InputStream is, Charset charset, int bufferSize)
static io.reactivex.Flowable<String>	from(Reader reader)
static io.reactivex.Flowable<String>	from(Reader reader, int bufferSize)
static io.reactivex.Flowable<String>	fromClasspath(Class<?> cls, String resource, Charset charset)
static io.reactivex.Flowable<String>	fromClasspath(String resource)
static io.reactivex.Flowable<String>	fromClasspath(String resource, Charset charset)
static io.reactivex.functions.Function<io.reactivex.Flowable<String>,io.reactivex.Maybe<String>>	join()
static io.reactivex.Maybe<String>	join(io.reactivex.Flowable<String> source)
static io.reactivex.Maybe<String>	join(io.reactivex.Flowable<String> source, String delimiter)
static io.reactivex.functions.Function<io.reactivex.Flowable<String>,io.reactivex.Maybe<String>>	join(String delimiter)
static io.reactivex.Flowable<String>	split(io.reactivex.Flowable<String> source, String pattern)
static io.reactivex.FlowableTransformer<String,String>	split(Pattern pattern)
static io.reactivex.FlowableTransformer<String,String>	split(Pattern pattern, io.reactivex.BackpressureStrategy backpressureStrategy, int batchSize)
static io.reactivex.FlowableTransformer<String,String>	split(String pattern)
static io.reactivex.FlowableTransformer<String,String>	split(String pattern, io.reactivex.BackpressureStrategy backpressureStrategy, int requestBatchSize)
static io.reactivex.Flowable<List<String>>	splitLinesSkipComments(InputStream is, Charset charset, String delimiter, String commentPrefix)
static <T> io.reactivex.FlowableTransformer<T,String>	strings()
static io.reactivex.Flowable<String>	strings(io.reactivex.Flowable<?> source)
static <T> io.reactivex.functions.Function<T,String>	trim()

Methods inherited from class java.lang.Object

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

Field Detail

UTF_8

public static final Charset UTF_8

Method Detail

trim

public static <T> io.reactivex.functions.Function<T,String> trim()

from

public static io.reactivex.Flowable<String> from(Reader reader,
                                                 int bufferSize)

from

public static io.reactivex.Flowable<String> from(Reader reader)

from

public static io.reactivex.Flowable<String> from(InputStream is)

from

public static io.reactivex.Flowable<String> from(InputStream is,
                                                 Charset charset)

from

public static io.reactivex.Flowable<String> from(InputStream is,
                                                 Charset charset,
                                                 int bufferSize)

split

public static io.reactivex.Flowable<String> split(io.reactivex.Flowable<String> source,
                                                  String pattern)

concat

public static io.reactivex.Maybe<String> concat(io.reactivex.Flowable<String> source)

concat

public static io.reactivex.Maybe<String> concat(io.reactivex.Flowable<String> source,
                                                String delimiter)

strings

public static io.reactivex.Flowable<String> strings(io.reactivex.Flowable<?> source)

from

public static io.reactivex.Flowable<String> from(File file)

from

public static io.reactivex.Flowable<String> from(File file,
                                                 Charset charset)

fromClasspath

public static io.reactivex.Flowable<String> fromClasspath(Class<?> cls,
                                                          String resource,
                                                          Charset charset)

fromClasspath

public static io.reactivex.Flowable<String> fromClasspath(String resource,
                                                          Charset charset)

fromClasspath

public static io.reactivex.Flowable<String> fromClasspath(String resource)

from

public static io.reactivex.Flowable<String> from(Callable<Reader> readerFactory)

join

public static io.reactivex.Maybe<String> join(io.reactivex.Flowable<String> source)

decode

public static io.reactivex.FlowableTransformer<byte[],String> decode(CharsetDecoder decoder)

decode

public static io.reactivex.FlowableTransformer<byte[],String> decode(CharsetDecoder decoder,
                                                                     io.reactivex.BackpressureStrategy backpressureStrategy,
                                                                     int requestBatchSize)

decode

public static io.reactivex.Flowable<String> decode(io.reactivex.Flowable<byte[]> source,
                                                   CharsetDecoder decoder)

decode

public static io.reactivex.Flowable<String> decode(io.reactivex.Flowable<byte[]> source,
                                                   Charset charset)

decode

public static io.reactivex.Flowable<String> decode(io.reactivex.Flowable<byte[]> source,
                                                   String charset)

join

public static io.reactivex.Maybe<String> join(io.reactivex.Flowable<String> source,
                                              String delimiter)

splitLinesSkipComments

public static io.reactivex.Flowable<List<String>> splitLinesSkipComments(InputStream is,
                                                                         Charset charset,
                                                                         String delimiter,
                                                                         String commentPrefix)

split

public static io.reactivex.FlowableTransformer<String,String> split(String pattern)

split

public static io.reactivex.FlowableTransformer<String,String> split(Pattern pattern)

split

public static io.reactivex.FlowableTransformer<String,String> split(String pattern,
                                                                    io.reactivex.BackpressureStrategy backpressureStrategy,
                                                                    int requestBatchSize)

split

public static io.reactivex.FlowableTransformer<String,String> split(Pattern pattern,
                                                                    io.reactivex.BackpressureStrategy backpressureStrategy,
                                                                    int batchSize)

join

public static io.reactivex.functions.Function<io.reactivex.Flowable<String>,io.reactivex.Maybe<String>> join(String delimiter)

join

public static io.reactivex.functions.Function<io.reactivex.Flowable<String>,io.reactivex.Maybe<String>> join()

concat

public static io.reactivex.functions.Function<io.reactivex.Flowable<String>,io.reactivex.Maybe<String>> concat(String delimiter)

concat

public static io.reactivex.functions.Function<io.reactivex.Flowable<String>,io.reactivex.Maybe<String>> concat()

strings

public static <T> io.reactivex.FlowableTransformer<T,String> strings()