From 875ce0328d1d919d639797972e4cf60c6715503f Mon Sep 17 00:00:00 2001
From: "Claudius \"keldu\" Holeksa" <mail@keldu.de>
Date: Tue, 21 May 2024 12:13:10 +0200
Subject: Fixing up echo builders and names

---
 modules/io_codec/examples/echo_client.cpp | 70 -------------------------------
 1 file changed, 70 deletions(-)
 delete mode 100644 modules/io_codec/examples/echo_client.cpp

(limited to 'modules/io_codec/examples/echo_client.cpp')

diff --git a/modules/io_codec/examples/echo_client.cpp b/modules/io_codec/examples/echo_client.cpp
deleted file mode 100644
index dadf5e0..0000000
--- a/modules/io_codec/examples/echo_client.cpp
+++ /dev/null
@@ -1,70 +0,0 @@
-#include "../c++/io_peer.hpp"
-
-#include <array>
-#include <iostream>
-
-#include "echo.hpp"
-
-int main(){
-	/**
-	 * Create EventLoop
-	 * Setup EventPort to the outside world
-	 * And setup the io comms to the outside.
-	 */
-	auto eo_aio = saw::setup_async_io();
-	if(eo_aio.is_error()){
-		auto& err = eo_aio.get_error();
-		std::cerr<<err.get_message()<<std::endl;
-		return err.get_id();
-	}
-	auto& aio = eo_aio.get_value();
-	/**
-	 * Make the event loop the current event loop on this thread
-	 */
-	saw::wait_scope wait_scope{aio.event_loop};
-
-	bool keep_running = true;
-	aio.event_port.on_signal(saw::Signal::Terminate).then([&keep_running](){
-		keep_running = false;
-	}).detach();
-
-	saw::own<saw::network_address> net_addr = nullptr;
-	saw::own<saw::async_io_stream> async_rmt = nullptr;
-
-	std::array<uint8_t, 32> read_data;
-	uint64_t read_bytes = 0;
-	auto& network = aio.io->get_network();
-	network.resolve_address(saw::echo_address, saw::echo_port).then([&](auto addr){
-		net_addr = std::move(addr);
-		network.connect(*net_addr).then([&](auto rmt_srv){
-			async_rmt = saw::heap<saw::async_io_stream>(std::move(rmt_srv));
-			async_rmt->write("foo", 3);
-
-			async_rmt->read(&read_data[0], 3, read_data.size()-1);
-
-			async_rmt->read_done().then([&](size_t b){
-	
-					std::cout<<"Received bytes:\n"<<std::endl;
-					for(uint64_t i = 0; i < b; ++i){
-						std::cout<<static_cast<char>(read_data[i]);
-					}
-					std::cout<<std::endl;
-
-					keep_running = false;
-			}).detach();
-
-			async_rmt->on_read_disconnected().then([&](){
-				keep_running = false;
-			}).detach();
-		}).detach();
-	}).detach();
-
-	wait_scope.poll();
-	while(keep_running){
-		wait_scope.wait();
-	}
-
-	std::cout<<"Shutting down echo client"<<std::endl;
-
-	return 0;
-}
-- 
cgit v1.2.3