Method read

test/unit/StreamingTest.cpp:144–159

    }

    virtual point_count_t read(PointViewPtr view, point_count_t numPts)
    {

        PointId idx = view->size();
        point_count_t cnt = 0;
        PointRef point(*view);
        while (cnt < numPts)
        {
            point.setPointId(idx);
            if (!processOne(point))
                break;
            cnt++;
            idx++;
        }
        return cnt;
     }

private:
    bool m_entered;