Merge pull request #4 from asiries335/mvp-4

Mvp 4

README.md

@@ -16,9 +16,6 @@ listening to a stream as event-loop
 
 ## Info
 
-Work with Redis occurs through the package Predis
-(https://github.com/nrk/predis)
-
 Need version Redis >= 5.0
 
 ## Install
@@ -73,6 +70,21 @@ $client->stream('test')->add(
 );
 ```
 
+_Find a message by id_
+
+```php
+
+$message = $client->stream('test')->findById('1599404282894-0');
+
+// result.
+Asiries335\redisSteamPhp\Data\Message {
+  -_id: "1599404282894-0"
+  -_key: "user"
+  -_body: "{"id":123,"name":"Barney","age":25}"
+}
+
+```
+
 _Delete a message_
 
 ```php

src/Stream.php

@@ -72,6 +72,34 @@ public function add(string $key, array $values) : string
         }
     }
 
+    /**
+     * Find a message by id
+     *
+     * @param string $id  Id Message
+     *
+     * @return Message
+     *
+     * @throws \Exception
+     *
+     */
+    public function findById(string $id) : Message
+    {
+        $item = $this->_client->call(
+            Constants::COMMAND_XREAD,
+            'STREAMS',
+            $this->_streamName,
+            $id
+        );
+
+        if (empty($item) === true) {
+            return new Message;
+        }
+
+        $message = new MessageHydrator();
+
+        return $message->hydrate($item[0][1][0], Message::class);
+    }
+
     /**
      * Removes the messages entries from a stream
      *