blob: c8b023a2b38bdfad8c04b2ec27585a215ecd04cd [file] [log] [blame]
import java.util.function.Consumer;
class Pipeline<I, O> implements Consumer<I> {
@Override public final void accept(I input) {}
public <K> void then(Pipeline<O, K> pipeline, final Observable<O> observable) {
observable.subscribe(pipeline::accept);
}
}
interface Observable<T> {
void subscribe(Consumer<T> x);
}