---

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

# ifndef __pipestream_h
# define __pipestream_h

# include "PipeModules.h"
# include <iostream.h>

// Output stream class

class OstreamWrapper {
  ostream * x ;

 public:
  OstreamWrapper() : x(0) {}
  OstreamWrapper( ostream& outs ) : x(&outs) {}
  OstreamWrapper operator= (OstreamWrapper w) { x=w.x; return *this; }
  template<class T>
  OstreamWrapper operator <<(T t) { (*x)<<t ; return *this; }
};
typedef Pipe<OstreamWrapper> PipeOStream ;

Pipe<OstreamWrapper> liftP( ostream& outs ) {
  return Pipe<OstreamWrapper>(outs);
}

// Input Stream class

template <class T>
class IStreamModule : public PipeModule<T> {
  istream * ins ;

 protected:

  inline void check(void) { PipeModule<T>::check( ins ); }

 public:
  IStreamModule( istream& ins ) : ins(&ins) {}

  T compute_local_fn( int fc )
    {
      check() ;
      T t ;
      (*ins) >> t ;
      if( !(ins->good()) ) throw BrokenPipe() ; 
      return t ;
    }
};

template<class T>
Pipe<T> liftP( istream& ins ) {
  return Pipe<T>(new IStreamModule<T>(ins));
}

// Output for Pair

template <class T1, class T2>
ostream &operator << (ostream &outs,Pair<T1,T2> v)
{
  return outs << "(" << v.lval << ", " << v.rval << ")";
}
    
# endif //__pipestream.h

---