diff options
author | Matthias Schiffer <mschiffer@universe-factory.net> | 2010-07-11 12:03:52 +0200 |
---|---|---|
committer | Matthias Schiffer <mschiffer@universe-factory.net> | 2010-07-11 12:03:52 +0200 |
commit | efdd8b44b2fcc7fcf4f7ba37ac4045793be8fecd (patch) | |
tree | ffdd106d614cecb7281ae533e7dd5659ca66e871 /src/PacketHandler.vala | |
parent | 21dd3cb9a40b6bef5dbea8534557c3d6c0eebed8 (diff) | |
download | eva-efdd8b44b2fcc7fcf4f7ba37ac4045793be8fecd.tar eva-efdd8b44b2fcc7fcf4f7ba37ac4045793be8fecd.zip |
Many API improvements and more bugfixes
Diffstat (limited to 'src/PacketHandler.vala')
-rw-r--r-- | src/PacketHandler.vala | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/PacketHandler.vala b/src/PacketHandler.vala index 0f5cd3c..b2ef1f7 100644 --- a/src/PacketHandler.vala +++ b/src/PacketHandler.vala @@ -3,6 +3,7 @@ namespace Eva { private DataInputStream istream; private DataOutputStream ostream; private int sizeLength; + private bool running = false; public signal void received_term(Term term); @@ -37,7 +38,7 @@ namespace Eva { } private async void receive() throws Error { - while(true) { + while(running) { while(istream.get_available() < sizeLength) { yield istream.fill_async((ssize_t)(sizeLength - istream.get_available()), 0, null); } @@ -71,6 +72,7 @@ namespace Eva { } public void start() { + running = true; receive.begin(); } } |