logos-storage/nim-json-rpc
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-json-rpc.git synced 2026-01-08 16:43:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove delegate proc for processClient

Browse Source
This commit is contained in:
coffeepots 2018-06-14 17:11:58 +01:00
parent 20ddb0267f
commit 30b97e7131
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
rpcstreamservers.nim
View File

@ -7,11 +7,7 @@ macro debug(body: varargs[untyped]): untyped = newStmtList()
macro info(body: varargs[untyped]): untyped = newStmtList()
macro error(body: varargs[untyped]): untyped = newStmtList()
type
RpcStreamServer* = RpcServer[StreamServer]
proc streamServerProcess(server: StreamServer, client: StreamTransport) {.async.} =
result = processClient(server, client)
type RpcStreamServer* = RpcServer[StreamServer]
proc newRpcStreamServer*(addresses: openarray[TransportAddress]): RpcStreamServer =
## Create new server and assign it to addresses ``addresses``.
@ -22,7 +18,7 @@ proc newRpcStreamServer*(addresses: openarray[TransportAddress]): RpcStreamServe
for item in addresses:
try:
info "Creating server on ", address = $item
var server = createStreamServer(item, streamServerProcess, {ReuseAddr},
var server = createStreamServer(item, processClient, {ReuseAddr},
udata = result)
result.servers.add(server)
except:
@ -30,7 +26,6 @@ proc newRpcStreamServer*(addresses: openarray[TransportAddress]): RpcStreamServe
if len(result.servers) == 0:
# Server was not bound, critical error.
# TODO: Custom RpcException error
raise newException(RpcBindError, "Unable to create server!")
proc newRpcStreamServer*(addresses: openarray[string]): RpcServer[StreamServer] =