ChangeLogTag:Thu Jan 1 15:20:30 2004 Steve Huston <shuston@riverace.com>

1 files changed, 34 insertions, 0 deletions

diff --git a/examples/APG/Streams/CommandStream.h b/examples/APG/Streams/CommandStream.h
new file mode 100644
index 00000000000..a8406436a76
--- /dev/null
+++ b/examples/APG/Streams/CommandStream.h
@@ -0,0 +1,34 @@
+/* -*- C++ -*- */
+// $Id$
+
+#ifndef COMMAND_STREAM_H
+#define COMMAND_STREAM_H
+
+#include "ace/Module.h"
+#include "ace/Stream.h"
+#include "ace/SOCK_Stream.h"
+
+#include "Command.h"
+#include "CommandTasks.h"
+
+// A CommandStream is a bidirectional ACE_Stream implementing a chain
+// of commands. A message will move down the stream until a
+// CommandModule is capable of processing it. After processing, it
+// will move on down the stream to the end. Data received from the
+// tail will likewise move up the stream until the downstream's
+// partner module is encoutered. The retrieved data will be processed
+// and continue on up the stream.
+
+// Listing 01 code/ch18
+class CommandStream : public ACE_Stream<ACE_MT_SYNCH>
+{
+public:
+  typedef ACE_Stream<ACE_MT_SYNCH> inherited;
+
+  CommandStream () : inherited()  { }
+  int open (ACE_SOCK_Stream *peer);
+  Command *execute (Command *command);
+};
+// Listing 01
+
+#endif /* COMMAND_STREAM_H */