Create an Observable that emits each char in the source String.

src/main/java/rx/Observable.java

@@ -1189,6 +1189,44 @@ public final static <T> Observable<T> from(T[] array) {
         return from(Arrays.asList(array));
     }
 
+    /**
+     * Converts an String into an Observable that emits the chars in the String.
+     * <p>
+     * <img width="640" height="315" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/from.png" alt="">
+     * <dl>
+     *  <dt><b>Scheduler:</b></dt>
+     *  <dd>{@code from} does not operate by default on a particular {@link Scheduler}.</dd>
+     * </dl>
+     *
+     * @param str
+     *            the source String
+     * @return an Observable that emits each char in the source String
+     * @see <a href="https://github.com/ReactiveX/RxJava/wiki/Creating-Observables#from">RxJava wiki: from</a>
+     */
+    public final static Observable<String> from(final String str) {
+        return Observable.create(new OnSubscribe<String>() {
+            @Override
+            public void call(Subscriber<? super String> subscriber) {
+                try {
+                    // Start emitting token's char
+                    for (Character c : str.toCharArray()) {
+                        subscriber.onNext(c.toString());
+                    }
+
+                    // Notify on completed
+                    if (!subscriber.isUnsubscribed()) {
+                        subscriber.onCompleted();
+                    }
+                } catch (Throwable t) {
+                    // Notify on error
+                    if (!subscriber.isUnsubscribed()) {
+                        subscriber.onError(t);
+                    }
+                }
+            }
+        });
+    }
+
     /**
      * Returns an Observable that emits a sequential number every specified interval of time.
      * <p>

src/test/java/rx/ObservableTests.java

@@ -114,6 +114,15 @@ public void fromArityArgs1() {
         assertEquals("one", items.takeLast(1).toBlocking().single());
     }
 
+    @Test
+    public void fromString(){
+        String foo = "foo";
+
+        assertEquals("f", Observable.from(foo).first().toBlocking().single());
+        assertEquals("o", Observable.from(foo).skip(1).take(1).toBlocking().single());
+        assertEquals("o", Observable.from(foo).takeLast(1).toBlocking().single());
+    }
+
     @Test
     public void testCreate() {