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<String,String>	splitSimple(String delimiter) Splits on a string delimiter, not a pattern.
static <T> io.reactivex.FlowableTransformer<T,String>	strings()
static io.reactivex.Flowable<String>	strings(io.reactivex.Flowable<?> source)
static InputStream	toInputStream(org.reactivestreams.Publisher<String> publisher) Returns an InputStream that offers the concatenated String data emitted by a subscription to the given publisher using the character set UTF-8 for the bytes read through the InputStream.
static InputStream	toInputStream(org.reactivestreams.Publisher<String> publisher, Charset charset) Returns an InputStream that offers the concatenated String data emitted by a subscription to the given publisher using the given character set.
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()

splitSimple

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

Splits on a string delimiter, not a pattern. Is slower than RxJavaString 1.1.1 implementation on benchmarks below but requests minimally from upstream and is potentially much faster when the stream is significantly truncated (for example by downstream .take(), .takeUntil(), elementAt().

 Benchmark                                  Mode  Cnt       Score       Error  Units
 Benchmarks.splitRxJavaString              thrpt   10     983.128 ±    23.833  ops/s
 Benchmarks.splitRxJavaStringTake5         thrpt   10    1033.090 ±    33.083  ops/s
 Benchmarks.splitSimple                    thrpt   10     113.727 ±     2.122  ops/s
 Benchmarks.splitSimpleTake5               thrpt   10  867527.265 ± 27168.498  ops/s
 Benchmarks.splitStandard                  thrpt   10     108.880 ±     4.428  ops/s
 Benchmarks.splitStandardTake5             thrpt   10    1217.798 ±    44.237  ops/s
 Benchmarks.splitStandardWithPattern       thrpt   10     102.882 ±     5.083  ops/s
 Benchmarks.splitStandardWithPatternTake5  thrpt   10    1054.024 ±    27.906  ops/s
 

Type Parameters:

T - type being streamed

Parameters:

delimiter - string delimiter

Returns:

stream split by delimiter

toInputStream

public static InputStream toInputStream(org.reactivestreams.Publisher<String> publisher,
                                        Charset charset)

Returns an InputStream that offers the concatenated String data emitted by a subscription to the given publisher using the given character set.

Parameters:

publisher - the source of the String data

charset - the character set of the bytes to be read in the InputStream

Returns:

offers the concatenated String data emitted by a subscription to the given publisher using the given character set

toInputStream

public static InputStream toInputStream(org.reactivestreams.Publisher<String> publisher)

Returns an InputStream that offers the concatenated String data emitted by a subscription to the given publisher using the character set UTF-8 for the bytes read through the InputStream.

Parameters:

publisher - the source of the String data

Returns:

offers the concatenated String data emitted by a subscription to the given publisher using the UTF-8 character set