debian-packages/vibe-core
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

added TCPConnection.waitForDataAsync

Browse source
This commit is contained in:
Francesco Mecca 2018-02-21 22:17:18 +00:00
parent c15864f5e2
commit 0d6ba62f51
1 changed files with 25 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
source/vibe/core/net.d
View file

@ -586,6 +586,31 @@ mixin(tracer);
return m_context.readBuffer.length > 0; return m_context.readBuffer.length > 0;
} }
void waitForDataAsync(void delegate(bool) @safe read_callback, Duration timeout = Duration.max)
{
mixin(tracer);
import vibe.core.core : runTask;
if (!m_context) {
runTask(read_callback, false);
return;
}
if (m_context.readBuffer.length > 0) {
runTask(read_callback, true);
return;
}
auto mode = timeout <= 0.seconds ? IOMode.immediate : IOMode.once;
bool cancelled;
IOStatus status;
size_t nbytes;
eventDriver.sockets.waitForData(m_socket,
(sock, st, nb) { if(st != IOStatus.ok) runTask(read_callback, false);
else runTask(read_callback, true);
});
}
const(ubyte)[] peek() { return m_context ? m_context.readBuffer.peek() : null; } const(ubyte)[] peek() { return m_context ? m_context.readBuffer.peek() : null; }
void skip(ulong count) void skip(ulong count)