diff --git a/source/vibe/core/core.d b/source/vibe/core/core.d
index b34b876..419dd0e 100644
--- a/source/vibe/core/core.d
+++ b/source/vibe/core/core.d
@@ -991,7 +991,7 @@ struct FileDescriptorEvent {
 		alias readwaiter = Waitable!(IOCallback,
 			cb => eventDriver.sockets.waitForData(m_socket, cb),
 			cb => eventDriver.sockets.cancelRead(m_socket),
-			(StreamSocketFD fd, IOStatus st, size_t nb) { got_data = st == IOStatus.ok; }
+			(fd, st, nb) { got_data = st == IOStatus.ok; }
 		);
 
 		asyncAwaitAny!(true, readwaiter)(timeout);
diff --git a/source/vibe/core/net.d b/source/vibe/core/net.d
index cc842ad..e1aeabe 100644
--- a/source/vibe/core/net.d
+++ b/source/vibe/core/net.d
@@ -201,7 +201,7 @@ TCPConnection connectTCP(NetworkAddress addr, NetworkAddress bind_address = anyA
 
 		alias waiter = Waitable!(ConnectCallback,
 			cb => eventDriver.sockets.connectStream(uaddr, baddr, cb),
-			(ConnectCallback cb, StreamSocketFD sock_fd) {
+			(cb, sock_fd) {
 				cancelled = true;
 				eventDriver.sockets.cancelConnectStream(sock_fd);
 			},
@@ -610,7 +610,7 @@ mixin(tracer);
 			determined or the specified timeout is reached.
 	*/
 	WaitForDataAsyncStatus waitForDataAsync(CALLABLE)(CALLABLE read_ready_callback, Duration timeout = Duration.max)
-		if (is(typeof(read_ready_callback(true))))
+		if (is(typeof(() @safe { read_ready_callback(true); } ())))
 	{
 mixin(tracer);
 		import vibe.core.core : setTimer;