shard reader: do not take self in delete (#95)

* shard reader: do not take `self` in `delete`

* rename

Author: alissa-tung

src/hstreamdb/src/reader.rs

@@ -64,7 +64,7 @@ impl Client {
 }
 
 impl ShardReader {
-    pub async fn read_shard(
+    pub async fn read(
         &self,
         max_records: u32,
     ) -> common::Result<Vec<(RecordId, Result<Payload, DecodeError>)>> {
@@ -89,11 +89,11 @@ impl ShardReader {
         Ok(records)
     }
 
-    pub async fn delete_shard_reader(self) -> common::Result<()> {
-        let mut channel = self.channels.channel_at(self.server_url).await?;
+    pub async fn delete(&self) -> common::Result<()> {
+        let mut channel = self.channels.channel_at(self.server_url.clone()).await?;
         channel
             .delete_shard_reader(DeleteShardReaderRequest {
-                reader_id: self.reader_id,
+                reader_id: self.reader_id.clone(),
             })
             .await?;
         Ok(())

src/x/hstreamdb-erl-nifs/src/lib.rs

@@ -760,7 +760,7 @@ fn async_read_shard(
     max_records: u32,
 ) -> Term<'_> {
     let future = async move {
-        let result = shard_reader.0.read_shard(max_records).await;
+        let result = shard_reader.0.read(max_records).await;
         OwnedEnv::new().send_and_clear(&pid, |env| match result {
             Err(err) => (read_shard_reply(), error(), err.to_string()).encode(env),
             Ok(records) => (