Adapt to the latest FastStreams API

This commit is contained in:
Zahary Karadjov 2020-04-14 19:33:49 +03:00
parent 99c68d40f7
commit 8f3bf36054
No known key found for this signature in database
GPG Key ID: C8936F8A3073D609
1 changed files with 3 additions and 3 deletions

View File

@ -160,7 +160,7 @@ when tracingEnabled:
logMsgEventImpl = ident "logMsgEventImpl" logMsgEventImpl = ident "logMsgEventImpl"
result = quote do: result = quote do:
var `tracerStream` = init OutputStream var `tracerStream` = memoryOutput()
var `tracer` = JsonWriter.init(`tracerStream`) var `tracer` = JsonWriter.init(`tracerStream`)
beginRecord(`tracer`) beginRecord(`tracer`)
@ -601,7 +601,7 @@ proc useStandardBody*(sendProc: SendProc,
mixin init, WriterType, beginRecord, endRecord, getOutput mixin init, WriterType, beginRecord, endRecord, getOutput
`initResultFuture` `initResultFuture`
var `outputStream` = init OutputStream var `outputStream` = memoryOutput()
`preSerialization` `preSerialization`
`serilization` `serilization`
`postSerialization` `postSerialization`
@ -614,7 +614,7 @@ proc correctSerializerProcParams(params: NimNode) =
# 1. it has a void return type # 1. it has a void return type
params[0] = ident "void" params[0] = ident "void"
# 2. The peer params is replaced with OutputStream # 2. The peer params is replaced with OutputStream
params[1] = newIdentDefs(streamVar, bindSym "OutputStreamVar") params[1] = newIdentDefs(streamVar, bindSym "OutputStream")
# 3. The timeout param is removed # 3. The timeout param is removed
params.del(params.len - 1) params.del(params.len - 1)