implement getSubset call

@@ -36,2 +36,4 @@
     /// JSON serialization or deserialization error.
     SerdeJson(JsonError),
+    /// Error decoding typed ssb message from content.
+    ContentTypeDecode(String),

@@ -48,6 +50,7 @@ impl std::error::Error for GolgiError {
             GolgiError::Rpc(ref err) => Some(err),
             GolgiError::Sbot(_) => None,
             GolgiError::SerdeJson(ref err) => Some(err),
+            GolgiError::ContentTypeDecode(ref _err) => None,

@@ -0,0 +32,4 @@
+impl SsbMessageValue {
+    /// Gets the type field of the message content if found,
+    /// and if not returns "none"
+    pub fn get_message_type(&self) -> String {

@@ -0,0 +58,4 @@
+#[derive(Serialize, Deserialize, Debug)]
+#[serde(deny_unknown_fields)]
+#[allow(missing_docs)]
+pub struct SsbKVT {

@@ -100,0 +103,4 @@
+
+    /// Call the `createLogStream` RPC method and return a Vec<Message>
+    pub async fn log(&mut self) -> Result<String, GolgiError> {
+        let req_id = self.client.log_req_send().await?;

@@ -26,2 +26,4 @@
+/// * `body` - An array of u8 to be parsed.
+pub fn string_res_parse(body: &[u8]) -> Result<String, GolgiError> {
     // TODO: cleanup with proper error handling etc.
     Ok(std::str::from_utf8(body).unwrap().to_string())

@@ -54,0 +104,4 @@
+/// * `f` - A function which takes in an array of u8 and returns a Result<T, GolgiError>.
+/// This is a function which parses the response from the RpcReader. T is a generic type,
+/// so this parse function can return multiple possible types (String, json, custom struct etc.)
+pub async fn get_async_until_eof<'a, R, T, F>(