---

/home/slang/XVision2/src/Pipes/PipeSys.h

# ifndef _PIPSYS_H_
# define _PIPSYS_H_

# include "PipeEvents.h"

// Time in seconds. count from 0
extern Pipe<double> timePipe ;

// Helper class
class XVPipeTimer {
 protected:
  double nexttime ;
  double interval ;
  double endtime ; 
  bool forever ;
 public:
  XVPipeTimer( double total, double inter );  // total < 0 -> forever
  bool next(void);
};

// To run a pipe in a timable manner
template<class T> 
void runPipe( const Pipe<T>& pipe, 
           double interval = 0, double totaltime = -1 ) {
  XVPipeTimer t( totaltime, interval );
  Pipe<T> p(pipe);
  while( t.next() ) {
    try {
      p.next_value();
    }catch( BrokenPipe e ) {}
  }
}

// Raw terminal input -- not compatible with X
PipeEvents<char> getPipeInputStream( int fd = 0 );

# endif //_PIPSYS_H_

---