JObjectDemultiplexer.cc

Go to the documentation of this file.

#include <string>
#include <iostream>
#include <iomanip>
#include <vector>

#include "JLang/JSTDObjectReader.hh"
#include "JLang/JSTDObjectWriter.hh"
#include "JLang/JObjectMultiplexer.hh"
#include "JLang/JObjectDemultiplexer.hh"

#include "Jeep/JParser.hh"
#include "Jeep/JMessage.hh"

namespace {

  struct __A__ {
    /**
     * Constructor.
     *
     * \param  i      value
     */
    __A__(const int i) :
      i(i)
    {}


    /**
     * Get name.
     *
     * \return         name
     */
    virtual const char* getName() const
    {
      return "a";
    }


    /**
     * Equal operator.
     *
     * \param  first   first  object
     * \param  second  second object
     * \return         true if first and second object are equal; else false
     */
    friend inline bool operator==(const __A__& first, const __A__& second)
    {
      return first.i == second.i;
    }


    /**
     * Write object to output stream.
     *
     * \param  out     output stream
     * \param  object  object
     * \return         output stream
     */
    friend inline std::ostream& operator<<(std::ostream& out, const __A__& object)
    {
      return out << object.getName() << object.i; 
    }

    int i;
  };


  struct __B__ :
    public __A__
  {
    /**
     * Constructor.
     *
     * \param  i      value
     */
    __B__(const int i) :
      __A__(i)
    {}


    /**
     * Get name.
     *
     * \return         name
     */
    virtual const char* getName() const
    {
      return "b";
    }
  };
}


/**
 * \file
 *
 * Example program to test JLANG::JObjectMultiplexer and JLANG::JObjectDemultiplexer classes.
 * \author mdejong
 */
int main(int argc, char **argv)
{
  using namespace std;

  int         debug;

  try {

    JParser<> zap("Example program to test object multiplexing and demultiplexing.");

    zap['d'] = make_field(debug)      = 3;

    zap(argc, argv);
  }
  catch(const exception &error) {
    FATAL(error.what() << endl);
  }


  using namespace JPP;

  vector<__A__> a_in;
  vector<__B__> b_in;

  for (int i = 1; i != 4; ++i) {
    a_in.push_back(i);
    b_in.push_back(i);
  }

  if (debug >= debug_t) {
    cout << "a_in  "; copy(a_in.begin(), a_in.end(), ostream_iterator<__A__>(cout, " ")); cout << endl;
    cout << "b_in  "; copy(b_in.begin(), b_in.end(), ostream_iterator<__B__>(cout, " ")); cout << endl;
  }


  typedef JTYPELIST<__B__, __A__>::typelist  typelist;   // make sure base class is at end

  JSTDObjectReader<typelist> in;

  in.set(a_in);
  in.set(b_in);


  JSTDObjectWriter<typelist> out;

  vector<__A__> a_out;
  vector<__B__> b_out;

  out.set(a_out);
  out.set(b_out);


  JObjectMultiplexer<typelist>          multiplexer  (in);

  JObjectDemultiplexer<__A__, typelist> demultiplexer(out);


  multiplexer >> demultiplexer;

  if (debug >= debug_t) {
    cout << "a_out "; copy(a_out.begin(), a_out.end(), ostream_iterator<__A__>(cout, " ")); cout << endl;
    cout << "b_out "; copy(b_out.begin(), b_out.end(), ostream_iterator<__B__>(cout, " ")); cout << endl;
  }

  ASSERT(a_in == a_out);
  ASSERT(b_in == b_out);

  return 0;
}