diff options
Diffstat (limited to 'source/tanya/async/watcher.d')
| -rw-r--r-- | source/tanya/async/watcher.d | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/source/tanya/async/watcher.d b/source/tanya/async/watcher.d index 2bbccad..44b7a1d 100644 --- a/source/tanya/async/watcher.d +++ b/source/tanya/async/watcher.d @@ -6,7 +6,7 @@ * Copyright: Eugene Wissner 2016. * License: $(LINK2 https://www.mozilla.org/en-US/MPL/2.0/, * Mozilla Public License, v. 2.0). - * Authors: $(LINK2 mailto:belka@caraus.de, Eugene Wissner) + * Authors: $(LINK2 mailto:info@caraus.de, Eugene Wissner) */ module tanya.async.watcher; @@ -61,6 +61,7 @@ class ConnectionWatcher : Watcher */ this(Socket socket) @nogc { + incoming = Queue!IOWatcher(MmapPool.instance); socket_ = socket; } @@ -233,7 +234,7 @@ class IOWatcher : ConnectionWatcher { if (output.length) { - protocol.received(output[0..$]); + protocol.received(output[0 .. $]); output.clear(); } else |