Adding utility functions for observables of strings useful for processing non blocking IO.