Module golgi::utils

source · [−]
Expand description

Utility methods.

Functions

get_async

Take in an RPC request number along with a handling function and wait for an RPC response which matches the request number. Then, call the handling function on the response.

get_source_stream

Take in an RPC request number along with a handling function (parsing results of type T) and produce an async_std::stream::Stream of results of type T, where the handling function is called on all RpcReader responses which match the request number.

get_source_until_eof

Take in an RPC request number along with a handling function and call the handling function on all RPC responses which match the request number, appending the result of each parsed message to a vector until a CancelStreamResponse is found (marking the end of the stream).

json_res_parse

Parse an array of bytes (returned by an rpc call) into a serde_json::Value.

kvt_res_parse

Parse an array of bytes (returned by an rpc call) into a KVT.

print_source_until_eof

Take in an RPC request number along with a handling function and call the handling function on all responses which match the request number. Then, prints out the result of the handling function.

ssb_message_res_parse

Parse an array of bytes (returned by an rpc call) into an SsbMessageValue.

string_res_parse

Parse an array of bytes (returned by an rpc call) into a String.