Add example showing use of local::stream_protocol::iostream.

asio/src/Makefile.am

@@ -115,6 +115,7 @@ noinst_PROGRAMS = \
 if !WINDOWS_TARGET
 noinst_PROGRAMS += \
 	examples/local/connect_pair \
+	examples/local/iostream_client \
 	examples/local/stream_server \
 	examples/local/stream_client
 endif
@@ -386,6 +387,7 @@ examples_tutorial_daytime7_server_SOURCES = examples/tutorial/daytime7/server.cp
 
 if !WINDOWS_TARGET
 examples_local_connect_pair_SOURCES = examples/local/connect_pair.cpp
+examples_local_iostream_client_SOURCES = examples/local/iostream_client.cpp
 examples_local_stream_server_SOURCES = examples/local/stream_server.cpp
 examples_local_stream_client_SOURCES = examples/local/stream_client.cpp
 endif

asio/src/examples/local/iostream_client.cpp

@@ -0,0 +1,59 @@
+//
+// stream_client.cpp
+// ~~~~~~~~~~~~~~~~~
+//
+// Copyright (c) 2003-2008 Christopher M. Kohlhoff (chris at kohlhoff dot com)
+//
+// Distributed under the Boost Software License, Version 1.0. (See accompanying
+// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
+//
+
+#include <cstring>
+#include <iostream>
+#include "asio.hpp"
+
+#if defined(ASIO_HAS_LOCAL_SOCKETS)
+
+using asio::local::stream_protocol;
+
+enum { max_length = 1024 };
+
+int main(int argc, char* argv[])
+{
+  try
+  {
+    if (argc != 2)
+    {
+      std::cerr << "Usage: iostream_client <file>\n";
+      return 1;
+    }
+
+    asio::io_service io_service;
+
+    stream_protocol::endpoint ep(argv[1]);
+    stream_protocol::iostream s(ep);
+
+    using namespace std; // For strlen.
+    std::cout << "Enter message: ";
+    char request[max_length];
+    std::cin.getline(request, max_length);
+    size_t length = strlen(request);
+    s << request;
+
+    char reply[max_length];
+    s.read(reply, length);
+    std::cout << "Reply is: ";
+    std::cout.write(reply, length);
+    std::cout << "\n";
+  }
+  catch (std::exception& e)
+  {
+    std::cerr << "Exception: " << e.what() << "\n";
+  }
+
+  return 0;
+}
+
+#else // defined(ASIO_HAS_LOCAL_SOCKETS)
+# error Local sockets not available on this platform.
+#endif // defined(ASIO_HAS_LOCAL_SOCKETS)