summaryrefslogtreecommitdiffstats
path: root/src/PacketHandler.vala
diff options
context:
space:
mode:
authorMatthias Schiffer <mschiffer@universe-factory.net>2010-07-11 12:03:52 +0200
committerMatthias Schiffer <mschiffer@universe-factory.net>2010-07-11 12:03:52 +0200
commitefdd8b44b2fcc7fcf4f7ba37ac4045793be8fecd (patch)
treeffdd106d614cecb7281ae533e7dd5659ca66e871 /src/PacketHandler.vala
parent21dd3cb9a40b6bef5dbea8534557c3d6c0eebed8 (diff)
downloadeva-efdd8b44b2fcc7fcf4f7ba37ac4045793be8fecd.tar
eva-efdd8b44b2fcc7fcf4f7ba37ac4045793be8fecd.zip
Many API improvements and more bugfixes
Diffstat (limited to 'src/PacketHandler.vala')
-rw-r--r--src/PacketHandler.vala4
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();
}
}