Update modules/streams/src/main/scala/dev/profunktor/redis4cats/pubsub/PubSubCommands.scala

yisraelU · mmienko · web-flow · commit 5acab8729cb0 · 2025-12-29T17:17:54.000-05:00
Co-authored-by: Michael Mienko &lt;mmienko@users.noreply.github.com&gt;
diff --git a/modules/streams/src/main/scala/dev/profunktor/redis4cats/pubsub/PubSubCommands.scala b/modules/streams/src/main/scala/dev/profunktor/redis4cats/pubsub/PubSubCommands.scala
@@ -28,7 +28,7 @@ import dev.profunktor.redis4cats.data._
   * @tparam V
   *   the value type
   */
-trait PublishCommands[F[_], S[_], K, V] extends algebra.Publish[F, K, V] with algebra.PubSubStats[F, K] {
+trait PublishCommands[F[_], S[_], K, V] extends algebra.PublishAndStats[F, K, V] {
 
   /** Streaming publish: transforms a stream of values into a stream of subscriber counts.
     *

Original file line number	Diff line number	Diff line change
`@@ -28,7 +28,7 @@ import dev.profunktor.redis4cats.data._`
`28`	`28`	`* @tparam V`
`29`	`29`	`* the value type`
`30`	`30`	`*/`
`31`		`-trait PublishCommands[F[_], S[_], K, V] extends algebra.Publish[F, K, V] with algebra.PubSubStats[F, K] {`
	`31`	`+trait PublishCommands[F[_], S[_], K, V] extends algebra.PublishAndStats[F, K, V] {`
`32`	`32`
`33`	`33`	`/** Streaming publish: transforms a stream of values into a stream of subscriber counts.`
`34`	`34`	`*`