From 19c8e8bc89aee1de10658af4ee28ede7846d1355 Mon Sep 17 00:00:00 2001
From: birme <jonas.birme@eyevinn.se>
Date: Mon, 29 Jun 2020 15:24:16 +0200
Subject: [PATCH] A client server example

---
 examples/client.js | 16 ++++++++++++++++
 examples/server.js | 19 +++++++++++--------
 2 files changed, 27 insertions(+), 8 deletions(-)
 create mode 100644 examples/client.js

diff --git a/examples/client.js b/examples/client.js
new file mode 100644
index 0000000..43c2ec7
--- /dev/null
+++ b/examples/client.js
@@ -0,0 +1,16 @@
+const fs = require('fs');
+const { SRTWriteStream } = require('../index.js');
+
+const source = fs.createReadStream(process.argv[2], { highWaterMark: 1316 });
+const srt = new SRTWriteStream('127.0.0.1', 1234);
+srt.connect(writeStream => {
+  source.pipe(writeStream);
+});
+srt.on('error', err => {
+  console.error(err.message);
+})
+
+process.on('SIGINT', () => {
+  console.log("Closing connection");
+  srt.close();
+});
\ No newline at end of file
diff --git a/examples/server.js b/examples/server.js
index 95de3fa..a106c16 100644
--- a/examples/server.js
+++ b/examples/server.js
@@ -1,11 +1,14 @@
-const { Server } = require('../index.js');
-
-const srtServer = new Server();
-
-srtServer.on("message", (msg, rinfo) => {
+const fs = require('fs');
+const { SRTReadStream } = require('../index.js');
 
+const dest = fs.createWriteStream('./output');
+const srt = new SRTReadStream('0.0.0.0', 1234);
+srt.listen(readStream => {
+  console.log("Client connected");
+  readStream.pipe(dest);
 });
-srtServer.on("listening", (address, port) => {
-  console.log(`SRT server listening on ${address}:${port}`);
+srt.on('end', () => {
+  console.log("Client disconnected");
 });
-srtServer.listen({ port: 1234 });
\ No newline at end of file
+
+console.log("Waiting for client to connect");