back to hunt 1.1.2

huntlabs · Mar 12, 2019 · c9a5780 · c9a5780
1 parent 75a3969
commit c9a5780
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/source/hunt/imf/io/client.d b/source/hunt/imf/io/client.d
@@ -1,6 +1,6 @@
 module hunt.imf.io.client;
 
-import hunt.collection.ByteBuffer;
+
 import hunt.net;
 
 import hunt.imf.core.dispatcher;
@@ -48,9 +48,9 @@ class Client
                 if(_close !is null)
                     _close(context);
             });
-            tcp.handler((ByteBuffer buffer) {
+            tcp.handler((in ubyte[] data) {
                 auto context = cast(Context)tcp.getAttachment();
-                auto list = context.parser.consume(cast(byte[])buffer.getRemaining());
+                auto list = context.parser.consume(cast(byte[])data);
                 foreach(p ; list)
                     _dispatcher.dispatch(context , p);
                 });   

diff --git a/source/hunt/imf/io/context.d b/source/hunt/imf/io/context.d
@@ -77,14 +77,14 @@ void sendMessage(M)(Context context,int64_t message_id , M m , VoidHandler finis
 {
     auto packet = new Packet(message_id ,  m.toProtobuf.array);
     auto data = packet.data;
-    context.sock.write(packet.data);
+    context.sock.write(packet.data , finish);
 }
 
 void sendMessage(Context context,int64_t message_id ,VoidHandler finish = null )
 {
     auto packet = new Packet(message_id);
     auto data = packet.data;
-    context.sock.write(packet.data);
+    context.sock.write(packet.data , finish);
 }
 
 void close(Context context)

diff --git a/source/hunt/imf/io/server.d b/source/hunt/imf/io/server.d
@@ -39,9 +39,9 @@ class Server
                     _close(context);
             });
             sock.handler(
-                (ByteBuffer buffer) {
+                (in ubyte[] data) {
                     auto context = cast(Context)tcp.getAttachment();
-                    auto list = context.parser.consume(cast(byte[])buffer.getRemaining());
+                    auto list = context.parser.consume(cast(byte[])data);
                     foreach(p ; list)
                         _dispatcher.dispatch(context , p);
                 }