package rx.broadcast;

import rx.Observable;

public interface Broadcast {
    Observable<Void> send(Object value);

    <T> Observable<T> valuesOfType(Class<T> clazz);
}

@@ -43,78 +43,643 @@
 e;%0A%0A
-public interface Broadcast %7B%0A    Observable%3CVoid%3E send(Object value);%0A
+/**%0A * A %7B@code Broadcast%7D represents both a producer and subscriber of messages.%0A */%0Apublic interface Broadcast %7B%0A    /**%0A     * Broadcasts the given value when the returned %7B@code Observable%7D is subscribed to.%0A     * @param value the value to broadcast%0A     * @return an Observable stream representing the message sent status%0A     */%0A    Observable%3CVoid%3E send(Object value);%0A%0A    /**%0A     * Returns a (hot) %7B@code Observable%7D stream of broadcasted values.%0A     * @param clazz the class type to filter the broadcasted values by%0A     * @param %3CT%3E the output stream type%0A     * @return an Observable stream of broadcasted values%0A     */
 %0A   

Add JavaDoc comments to Broadcast