Skip to content

String Observables

David Gross edited this page May 14, 2014 · 7 revisions

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


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

Clone this wiki locally