fix(client): adapt PR to request rework

Author: Snapstromegon

src/client/client_request/run_eventql_query.rs

@@ -1,6 +1,5 @@
-use futures::{Stream, StreamExt};
 use reqwest::Method;
-use serde::{Deserialize, Serialize};
+use serde::Serialize;
 
 use crate::error::ClientError;
 
@@ -24,30 +23,5 @@ impl ClientRequest for RunEventqlQueryRequest<'_> {
 
 impl StreamingRequest for RunEventqlQueryRequest<'_> {
     type ItemType = EventqlRow;
-
-    fn build_stream(
-        response: reqwest::Response,
-    ) -> impl Stream<Item = Result<Self::ItemType, ClientError>> {
-        #[derive(Deserialize, Debug)]
-        #[serde(tag = "type", content = "payload", rename_all = "camelCase")]
-        enum LineItem {
-            Error { error: String },
-            Row(EventqlRow),
-        }
-
-        impl From<LineItem> for Result<EventqlRow, ClientError> {
-            fn from(item: LineItem) -> Self {
-                match item {
-                    LineItem::Error { error } => Err(ClientError::DBError(error)),
-                    LineItem::Row(row) => Ok(row),
-                }
-            }
-        }
-
-        Self::lines_stream(response).map(|line| {
-            let line = line?;
-            let item = serde_json::from_str(line.as_str())?;
-            Ok(item)
-        })
-    }
+    const ITEM_TYPE_NAME: &'static str = "row";
 }