TcpServer Class

public static class TcpServer

using System;
using System.Threading.Tasks;
using Demo3D.Native;
using Demo3D.Net;
using Demo3D.Net.Protocols;
using Demo3D.Visuals;

namespace Examples.Net.TcpStreamServerExample {
    [Auto] public class Server {
        [Auto] IBuilder                 app;
        [Auto] Document                 doc;
        [Auto] PrintDelegate            print;
        [Auto] SimplePropertyValue<int> tcpPort;     // The port to run the server on.

        [Auto] void OnInitialize(Visual sender) {
            // Open a server on the configured tcpPort.
            // This variant of TcpServer.Open will open the server, and call ServiceConnectionAsync
            // for each connection accepted.
            TcpServer.Open(tcpPort, ServiceConnectionAsync);
        }

        async Task ServiceConnectionAsync(ServerClient<IByteStreamService> socket) {
            Console.WriteLine("Connection from " + socket.Address);

            var stream = socket.IO.Stream;

            // Simple server loops forever receiving messages and printing them to the log.
            for (;;) {
                var buffer  = new byte[4];
                var numRead = await stream.ReadAsync(buffer, 0, 4);
                Console.WriteLine("Message received: " + numRead);
                if (numRead == 0) break;
            }
        }
    }
}

using System;
using Demo3D.Native;
using Demo3D.Net;
using Demo3D.Net.Protocols;
using Demo3D.Visuals;

using Buffer = Demo3D.IO.Buffer;

namespace Examples.Net.TcpServerExample {
    [Auto] public class Server {
        [Auto] IBuilder                 app;
        [Auto] Document                 doc;
        [Auto] PrintDelegate            print;
        [Auto] SimplePropertyValue<int> tcpPort;     // The port to run the server on.

        [Auto] void OnInitialize(Visual sender) {
            // Open a server on the configured tcpPort.
            // This variant of TcpServer.Open will open the server, accept incoming connections and
            // wait for data to arrive on each of the connections.  It will then call ReceiveMessage
            // when data is received on any of the clients.
            TcpServer.Open(tcpPort, ReceiveMessage);
        }

        void ReceiveMessage(ProtocolSocket socket, object service, NotifyDataChangedEventArgs e) {
            try {
                var args    = (PacketChangedEventArgs)e;  // A TCP server uses PacketChangedEventArgs.
                var message = args.GetData();             // Read from the packet.

                // Handle the message.
                HandleMessage(message);
            }
            catch (Exception x) {
                socket.Close(x);
            }
        }

        void HandleMessage(Buffer message) {
            print("Message received: " + message.Length + " bytes");
        }
    }
}