Page MenuHomeHEPForge
Files F19244210

EvtStreamAdapter.hh
No OneTemporary
Actions

Size
3 KB
Referenced Files
None
Subscribers
None

EvtStreamAdapter.hh
View Options

/***********************************************************************
* Copyright 1998-2020 CERN for the benefit of the EvtGen authors *
* *
* This file is part of EvtGen. *
* *
* EvtGen is free software: you can redistribute it and/or modify *
* it under the terms of the GNU General Public License as published by *
* the Free Software Foundation, either version 3 of the License, or *
* (at your option) any later version. *
* *
* EvtGen is distributed in the hope that it will be useful, *
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
* GNU General Public License for more details. *
* *
* You should have received a copy of the GNU General Public License *
* along with EvtGen. If not, see <https://www.gnu.org/licenses/>. *
***********************************************************************/
#ifndef EVT_STREAM_ADAPTER_HH
#define EVT_STREAM_ADAPTER_HH
// Stream adapters are used to convert a stream-like input (for example,
// a file containing N entries) to an STL like iterator interface. There
// must be a way to get point from the stream, and also an indicator of the
// end of the stream.
template <class Point>
class EvtStreamAdapter {
public:
EvtStreamAdapter() {}
virtual ~EvtStreamAdapter() {}
virtual EvtStreamAdapter* clone() const = 0;
virtual Point currentValue() = 0;
virtual void advance() = 0;
virtual bool pastEnd() = 0;
};
// N points are read from a generated stream.
template <class Point, class Generator>
class EvtGenStreamAdapter : public EvtStreamAdapter<Point> {
public:
EvtGenStreamAdapter( Generator gen, int count ) :
_gen( gen ), _count( count )
{
}
virtual ~EvtGenStreamAdapter() {}
EvtStreamAdapter<Point>* clone() const override
{
return new EvtGenStreamAdapter( *this );
}
Point currentValue() override { return _gen(); }
bool pastEnd() override { return ( _count <= 0 ); }
void advance() override { _count--; }
private:
Generator _gen;
int _count; // also serves as past the end indicator
};
// Only points satisfying a predicate are read from the stream.
template <class Point, class Iterator, class Predicate>
class EvtPredStreamAdapter : public EvtStreamAdapter<Point> {
public:
EvtPredStreamAdapter( Predicate pred, Iterator it, Iterator end ) :
_pred( pred ), _it( it ), _end( end )
{
}
virtual ~EvtPredStreamAdapter() {}
virtual EvtStreamAdapter<Point>* clone() const
{
return new EvtPredStreamAdapter( *this );
}
virtual Point currentValue()
{
Point value;
while ( !pastEnd() ) {
value = *_it;
if ( _pred( value ) )
break;
_it++;
}
return value;
}
virtual bool pastEnd() { return _it == _end; }
virtual void advance() { _it++; }
private:
Predicate _pred;
Iterator _it;
Iterator _end;
};
#endif

File Metadata

Mime Type
text/x-c++
Expires
Tue, Sep 30, 4:40 AM (22 h, 37 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
6560434
Default Alt Text
EvtStreamAdapter.hh (3 KB)

Event Timeline

HEPForge.org · .