Types
RpcPipesProcessClient = proc (server: RpcPipesServer; input, output: StreamTransport): Future[void] {. async: (...raises: []).}
- Source Edit
RpcPipesServer = ref object of RpcServer loop*: Future[void].Raising([]) maxMessageSize*: int framing*: Framing processClientHook*: RpcPipesProcessClient
- Source Edit
Procs
proc closeWait(server: RpcPipesServer): InternalRaisesFuture[void, void] {. ...stackTrace: false, raises: [], gcsafe, raises: [], gcsafe, tags: [RootEffect], forbids: [].}
- Source Edit
proc newRpcPipesServer(maxMessageSize = defaultMaxMessageSize; framing = Framing.httpHeader()): RpcPipesServer {. ...raises: [], gcsafe, tags: [], forbids: [].}
- Source Edit
proc newRpcPipesServer(processClientHook: RpcPipesProcessClient; maxMessageSize = defaultMaxMessageSize; framing = Framing.httpHeader()): RpcPipesServer {. ...raises: [], gcsafe, tags: [], forbids: [].}
- Create new server with custom processClientHook. Source Edit
proc processClient(server: RpcPipesServer; input, output: StreamTransport): InternalRaisesFuture[ void, void] {....stackTrace: false, raises: [], gcsafe, raises: [], gcsafe, tags: [RootEffect], forbids: [].}
- Process transport data to the RPC server Source Edit
proc serve(server: RpcPipesServer): InternalRaisesFuture[void, (CancelledError, JsonRpcError)] {....stackTrace: false, raises: [], gcsafe, raises: [], gcsafe, tags: [RootEffect], forbids: [].}
- Serve the connection given to start until it ends. Cancelling it stops the connection, like stop. Source Edit
proc start(server: RpcPipesServer; input, output: StreamTransport) {. ...raises: [JsonRpcError], raises: [], gcsafe, tags: [RootEffect], forbids: [].}
- Source Edit
proc stop(server: RpcPipesServer): InternalRaisesFuture[void, void] {. ...stackTrace: false, raises: [], gcsafe, raises: [], gcsafe, tags: [RootEffect], forbids: [].}
- Source Edit
Exports
-
ParamsMismatchError, RpcResponseError, RpcInvalidRequestError, RequestDecodeError, ResultDecodeError, new, RpcMethodNotFoundError, RpcInternalError, FailedHttpResponse, RpcServerError, ApplicationError, JsonRpcError, RpcParseError, RpcApplicationError, RpcOrigin, RpcTransportError, InvalidRequest, RpcAddressUnresolvableError, RpcPostError, ErrorResponse, InvalidResponse, RpcInvalidParamsError, RpcBindError, ==, ResponseBatchRx, InvalidResponse, automaticBuiltinSerialization, new, METHOD_NOT_FOUND, call, hash, ResponseRx, RpcRouter, automaticBuiltinSerialization, RpcParseError, writeRequest, readValue, RpcServer, mimeType, JrpcSys, flavorRequiresAllFields, writeValue, call, flavorSkipNullFields, RequestDecodeError, flavorUsesAutomaticObjectSerialization, ApplicationError, processsSingleResponse, rpc, automaticPrimitivesSerialization, ResponseError, RpcBatchResponse, createRpcSigsFromNim, RpcOrigin, hash, call, typeAutoSerialize, executeMethod, $, RequestTx, prepareBatch, ParamsMismatchError, RpcInvalidParamsError, executeMethod, JSON_PARSE_ERROR, BidiMessageRequestError, ResponseRx2, RpcBatchItem, createSingleRpcSig, meth, readValue, INTERNAL_ERROR, flavorOmitsOptionalFields, toJsonError, readValue, flavorOmitsOptionalFields, readValue, automaticSerialization, INVALID_REQUEST, parseResponse, automaticPrimitivesSerialization, wrapError, GetJsonRpcRequestHeaders, FailedHttpResponse, RpcPostError, route, RpcServerError, RequestParamsTx, Reader, send, Writer, readValue, RequestParamKind, RequestId, RpcClient, BidiMessage, ResponseKind, createRpcSigsFromNim, withPendingFut, defaultMaxMessageSize, ParamDescRx, RequestRx2, automaticSerialization, RpcTransportError, JrpcConv, writeValue, ResponseFut, executeMethod, flavorEnumRep, typeClassOrMemberAutoSerialize, close, Writer, writeValue, hasMethod, RpcInvalidRequestError, createRpcSigsFromString, RequestParamsRx, JsonRpcError, typeClassOrMemberAutoSerialize, RpcInternalError, send, RpcRouterCallback, flavorSkipNullFields, rpc, flavorRequiresAllFields, notify, decode, readValue, PreferredOutputType, createSingleRpcSig, mimeType, flavorEnumRep, clear, RpcMethodNotFoundError, readValue, clearPending, route, ParamDescNamed, readValue, processMessage, writeValue, ResponseTx, hasMethod, ResultDecodeError, writeNotification, readValue, PreferredOutputType, InvalidRequestSysError, register, readValue, RpcBatchCallRef, unRegisterAll, JsonRPC2, flavorUsesAutomaticObjectSerialization, shouldWriteObjectField, writeValue, Reader, createRpcSigsFromString, createRpcSigs, new, callOnProcessMessage, readValue, rpc, BidiMessageResponseError, RpcApplicationError, writeValue, ReqRespHeader, RpcResponseError, executeMethod, meth, notify, decode, readValue, route, flavorAllowsUnknownFields, typeAutoSerialize, INVALID_PARAMS, flavorEnumRep, RequestRx, createRpcSigs, toTx, RequestIdKind, rpc, RpcAddressUnresolvableError, RpcProc, ReBatchKind, BidiMessageKind, register, readValue, flavorEnumRep, writeValue, InvalidRequest, init, ErrorResponse, withWriter, route, flavorAllowsUnknownFields, RequestBatchRx, rpc, RpcBindError, isFieldExpected, SERVER_ERROR, JSON_ENCODE_ERROR, RpcConnection, route, rpc, httpHeader, FramingRecvMsg, lengthHeaderBE32, init, FramingSendMsg, Framing, newLine