String Observables

The StringObservable class contains methods that represent operators particular to Observables that deal in string-based sequences and streams. These include:

• byLine( ) — converts an Observable of Strings into an Observable of Lines by treating the source sequence as a stream and splitting it on line-endings
• decode( ) — convert a stream of multibyte characters into an Observable that emits byte arrays that respect character boundaries
• encode( ) — transform an Observable that emits strings into an Observable that emits byte arrays that respect character boundaries of multibyte characters in the original strings
• from( ) — convert a stream of characters or a Reader into an Observable that emits byte arrays or Strings
• join( ) — converts an Observable that emits a sequence of strings into an Observable that emits a single string that concatenates them all, separating them by a specified string
• split( ) — converts an Observable of Strings into an Observable of Strings that treats the source sequence as a stream and splits it on a specified regex boundary
• stringConcat( ) — converts an Observable that emits a sequence of strings into an Observable that emits a single string that concatenates them all

---

byLine( )

converts an Observable of Strings into an Observable of Lines by treating the source sequence as a stream and splitting it on line-endings

---

decode( )

convert a stream of multibyte characters into an Observable that emits byte arrays that respect character boundaries

---

encode( )

transform an Observable that emits strings into an Observable that emits byte arrays that respect character boundaries of multibyte characters in the original strings

---

from( )

convert a stream of characters or a Reader into an Observable that emits byte arrays or Strings

Note that in the from(InputStream, size) and from(Reader, size) variants, the resulting Observable is unusual: you can only subscribe to it a single time. This means, for example, that operators like repeat( ) or retry( ) will not work on such an Observable.

---

join( )

converts an Observable that emits a sequence of strings into an Observable that emits a single string that concatenates them all, separating them by a specified string

---

split( )

converts an Observable of Strings into an Observable of Strings that treats the source sequence as a stream and splits it on a specified regex boundary

---

stringConcat( )

converts an Observable that emits a sequence of strings into an Observable that emits a single string that concatenates them all