public Stream<MyPojo> load MyPojo () {
        return StreamSupport.stream(new Spliterator<MyPojo>() {
            @Override
            public boolean tryAdvance(Consumer<? super MyPojo> action) {
                if(!dataStreamIsOpen()){
                   openStream();
                }
                if(!dataStreamIsOpen()){
                   MyPojo pj = readNext();
                   if(pj != null) {
                      action.accept(pj) ;
                      return true;
                   } else {
                      closeStream();
                   }
                }
                return false;
            }

            @Override
            public Spliterator<User> trySplit() {
                return null;
            }

            @Override
            public long estimateSize() {
                return total;
            }

            @Override
            public int characteristics() {
                return NONNULL;
            }
        }, false);
    }