summaryrefslogtreecommitdiff
path: root/CSharp/Ivy
diff options
context:
space:
mode:
authorfcolin2007-02-01 09:49:45 +0000
committerfcolin2007-02-01 09:49:45 +0000
commitb89886c3ffbde81ff550b854022e112844d22e3a (patch)
treefe60fdf74009cec6839cf9f116479fce8b133b76 /CSharp/Ivy
parent6ce63ac22f91bed925082c74ecd2c848391665d1 (diff)
downloadivy-csharp-b89886c3ffbde81ff550b854022e112844d22e3a.zip
ivy-csharp-b89886c3ffbde81ff550b854022e112844d22e3a.tar.gz
ivy-csharp-b89886c3ffbde81ff550b854022e112844d22e3a.tar.bz2
ivy-csharp-b89886c3ffbde81ff550b854022e112844d22e3a.tar.xz
Utilisateur : Fcolin Date : 19/12/05 Heure : 16:54 Créé Commentaire: (vss 1)
Diffstat (limited to 'CSharp/Ivy')
-rw-r--r--CSharp/Ivy/Ivy/IvyTCPStream.cs46
1 files changed, 46 insertions, 0 deletions
diff --git a/CSharp/Ivy/Ivy/IvyTCPStream.cs b/CSharp/Ivy/Ivy/IvyTCPStream.cs
new file mode 100644
index 0000000..3e2eebf
--- /dev/null
+++ b/CSharp/Ivy/Ivy/IvyTCPStream.cs
@@ -0,0 +1,46 @@
+using System;
+using System.Collections.Specialized;
+using System.Text;
+using System.Net;
+using System.Net.Sockets;
+using System.IO;
+
+namespace IvyBus
+{
+ abstract class IvyTCPStream : IvyProtocolInterface
+ {
+ protected NetworkStream stream;
+
+ public IvyTCPStream(Socket socket)
+ {
+ //stream = new BufferedStream(new NetworkStream(socket,true));
+ stream = new NetworkStream(socket, true);
+ }
+ internal void Close()
+ {
+ stream.Close();
+ }
+ abstract internal bool receiveMsg();
+
+ abstract public void TokenStartRegexp(ushort port, string appName);
+
+ abstract public void TokenEndRegexp();
+ abstract public void TokenApplicationId(ushort priority, string appId);
+
+ abstract public void TokenAddRegexp(ushort id, string bind);
+ abstract public void TokenAddBinding(ushort id, string bind);
+
+ abstract public void TokenDelBinding(ushort id);
+
+ abstract public void TokenDirectMsg(ushort id, string message);
+ abstract public void TokenPong(string s);
+ abstract public void TokenPing(string s);
+
+ abstract public void TokenBye(ushort id, string message);
+ abstract public void TokenDie(ushort id, string message);
+
+ abstract public void TokenMsg(ushort key, string[] args);
+
+ abstract public void TokenError(ushort key, string arg);
+ }
+}