From 824b078eaccf3e26c8416e5f0f044f1c0eb23e10 Mon Sep 17 00:00:00 2001
From: Tony Garnock-Jones <tonyg@leastfixedpoint.com>
Date: Fri, 18 Jun 2021 13:48:12 +0200
Subject: [PATCH] Simpler stream connection protocol.

---
 stream.prs | 22 +++++++---------------
 tcp.prs    |  2 --
 2 files changed, 7 insertions(+), 17 deletions(-)

diff --git a/stream.prs b/stream.prs
index a565087..a8c7ecc 100644
--- a/stream.prs
+++ b/stream.prs
@@ -1,24 +1,14 @@
 version 1 .
 embeddedType EntityRef.Ref .
 
-; Assertions
+; Assertion:
 StreamConnection = <stream-connection @source #!Source @sink #!Sink @spec any>.
-StreamSpecListenable = <stream-spec-listenable @spec any>.
-StreamSpecConnectable = <stream-spec-connectable @spec any>.
 
-; Assertion
-StreamListener = <stream-listener @spec any @handle #!ConnectionHandler>.
+; Assertions:
+StreamListenerReady = <stream-listener-ready @spec any>.
+StreamListenerError = <stream-listener-error @spec any @message string>.
 
-; Assertion
-StreamConnect = <stream-connect @spec any @handle #!ConnectionHandler>.
-
-; Assertion
-ConnectionHandler =
-  / @connected <stream-connected @source #!Source @sink #!Sink>
-  / @rejected <stream-rejected @message string>
-.
-
-; Assertion
+; Assertion:
 StreamError = <error @message string>.
 
 Source =
@@ -40,7 +30,9 @@ Sink =
   / <eof>
 .
 
+; Value:
 CreditAmount = @count int / @unbounded =unbounded .
 
+; Value:
 Mode = =bytes / @lines LineMode / <packet @size int> / <object @description any>.
 LineMode = =lf / =crlf .
diff --git a/tcp.prs b/tcp.prs
index b00df01..7a6d5e1 100644
--- a/tcp.prs
+++ b/tcp.prs
@@ -5,5 +5,3 @@ TcpRemote = <tcp-remote @host string @port int>.
 TcpLocal = <tcp-local @host string @port int>.
 
 TcpPeerInfo = <tcp-peer @handle #!any @local TcpLocal @remote TcpRemote>.
-
-TcpListenError = <tcp-listen-error @spec TcpLocal @message string>.