Add fromMasterReplica connection builder method to RedisStream (#967)

Co-authored-by: Michael Mienko <[email protected]>

Author: mmienko

modules/streams/src/main/scala/dev/profunktor/redis4cats/streams/Fs2Streaming.scala

@@ -63,9 +63,14 @@ object RedisStream {
       codec: RedisCodec[K, V],
       uris: RedisURI*
   )(readFrom: Option[JReadFrom] = None): Resource[F, Streaming[F, Stream[F, *], K, V]] =
-    RedisMasterReplica[F].make(codec, uris: _*)(readFrom).map { conn =>
-      new RedisStream(new RedisRawStreaming(conn.underlying))
-    }
+    RedisMasterReplica[F]
+      .make(codec, uris: _*)(readFrom)
+      .map(fromMasterReplica[F, K, V](_))
+
+  def fromMasterReplica[F[_]: Async, K, V](
+      connection: RedisMasterReplica[K, V]
+  ): Streaming[F, Stream[F, *], K, V] =
+    new RedisStream(new RedisRawStreaming(connection.underlying))
 
 }