class BlockingObservableNext implements Iterable<T> {

    @Override
    public Iterator<T> iterator() {
        NextObserver<T> nextObserver = new NextObserver<T>();
        return new NextIterator<T>(source, nextObserver);
    }

    public  BlockingObservableNext(ObservableSource<T> source);

}