blob: a0d6a21bf69c2591696b1c28d9c17e2cb9166895 [file] [log] [blame]
import java.util.function.Consumer;
import java.util.function.Function;
public interface Observable<T> {
void subscribe(Consumer<T> consumer);
default <R> Observable<R> map(Function<T, R> f) {
return new Observable<R>() {
@Override
public void subscribe(Consumer<T> consumer) {
Observable.this.subscribe(null);
}
};
}
}