import asyncnet, asyncdispatch
var sock = newAsyncSocket()
proc onConnect(future: Future[void]) =
echo("Connected in future!")
for i in 0 .. 50:
var recvF = recv(sock, 10)
recvF.callback =
proc (future: Future[string]) =
echo("Read ", future.read.len, ": ", future.read.repr)
var ft = connect(sock, "127.0.0.1", Port(12345))
ft.callback = onConnect
runForever()
error:
client.nim(13, 3) Error: type mismatch: got (Future[system.void], proc (future: Future[system.void]){.locks: <unknown>.})
but expected one of:
proc callback=(future: FutureBase; cb: proc ())
proc callback=[T](future: Future[T];
cb: proc (future: Future[T]))
Must remove connect or recv line can build it. (v0.14.2).
it's (future: Future[void]) bug?
It works when put it into a proc. But it does not do what I expect from it. It only reads 10 chars and in the next turn it reads nothing anymore.
import asyncnet, asyncdispatch
import asyncnet, asyncdispatch
proc main() =
var sock = newAsyncSocket()
proc onConnect() =
echo("Connected in future!")
asyncCheck sock.send("GET /\r\l\r\l")
for i in 0 .. 50:
var recvF = recv(sock, 10)
recvF.callback =
proc (future: Future[string]) =
echo("Read ", future.read.len, ": ", future.read.repr)
var ft = connect(sock, "nim-lang.org", Port(80))
ft.callback = onConnect
runForever()
main()
Your version is though to be GC unsafe by Nim complier --- the location of sock maybe not exist next pull by runForever(). Use nested function to remind complier to increase the reference count (for sock).
这样才是正确的：
import asyncnet, asyncdispatch
var sock = newAsyncSocket()
proc onConnect(sock: AsyncSocket, host: string, port: Port) =
var ft = connect(sock, host, port)
ft.callback = proc (future: Future[void]) =
echo("Connected in future!")
for i in 0 .. 50:
var recvF = recv(sock, 10)
recvF.callback =
proc (future: Future[string]) =
echo("Read ", future.read.len, ": ", future.read.repr)
sock.onConnect("irc.freenode.net", Port(6667))
runForever()
你的版本 onConnect 里边的 sock 被认为是 GC unsafe 不安全的 --- 编译器认为，搞不好下一次 pull 的时候，其内存已经不在了，所以不让你编译通过。
但是放在嵌套函数中，Nim 会在内部始终保存其一个指针副本，以增加 GC 引用计数。
:)
好吧, 不错！ 看来这里不适合用全局变量, 不过我就是用的官方例子改了下, 也是这个错误. (asyncnet.nim 最下面）
var sock = newAsyncSocket()
var f = connect(sock, "irc.freenode.net", Port(6667))
f.callback =
proc (future: Future[void]) =
echo("Connected in future!")
for i in 0 .. 50:
var recvF = recv(sock, 10)
recvF.callback =
proc (future: Future[string]) =
echo("Read ", future.read.len, ": ", future.read.repr)
之前我发的例子不知道关闭线程检测能不能编译成功, 回去试试.
OO!
It passed with {.gcsafe.} (我加了个 {.gcsafe.} 可以通过了)：
import asyncnet, asyncdispatch
var sock = newAsyncSocket()
var f = connect(sock, "irc.freenode.net", Port(6667))
f.callback =
proc (future: Future[void]) {.gcsafe.} =
echo("Connected in future!")
echo repr sock
for i in 0 .. 50:
var recvF = recv(sock, 10)
recvF.callback =
proc (future: Future[string]) =
echo("Read ", future.read.len, ": ", future.read.repr)
runForever()
Error if not {.gcsafe.} (如果不加的话，会出现 Error):
Error: type mismatch: got (Future[system.void], proc (future: Future[system.void]){.locks: <unknown>.})
but expected one of:
proc callback=(future: FutureBase; cb: proc ())
proc callback=[T](future: Future[T];
cb: proc (future: Future[T]))
However, recommend {.async.} (不过我还是建议你用 {.async.} , 省不少事情，性能其实损失不了多少):
import asyncnet, asyncdispatch
proc recvAll(sock: AsyncSocket) {.async.} =
for i in 0 .. 50:
var ret = await recv(sock, 10)
echo("Read ", ret.len, ": ", ret.repr)
proc main() {.async.} =
var sock = newAsyncSocket()
await sock.connect("irc.freenode.net", Port(6667))
await sock.recvAll()
waitFor main()
赞一下:)， 谢谢了， 知道怎么不报错就行。
用callback只是想更细致的操作buf, 也只是试试先， 最近才研究nim的async和threadpool这块.
Sorry, Don't care about details please.:)
This error maybe don't use global variables directly in proc can correct build it.
@OderWat
Don't mind.
@dom96
I would vote against sub-forums for different languages and rather suggest to anyone to use one of the translator plugins in modern browsers like:
https://addons.mozilla.org/id/firefox/addon/s3google-translator/
or others. Most people hardly have enough time to keep up with the main-forum.