Fixes Issue #135

debasishg · Apr 5, 2015 · b8851a0 · b8851a0
1 parent 72f380a
commit b8851a0
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 2 deletions.
diff --git a/project/ScalaRedisProject.scala b/project/ScalaRedisProject.scala
@@ -8,7 +8,7 @@ object ScalaRedisProject extends Build
 
   lazy val commonSettings: Seq[Setting[_]] = Seq(
     organization := "net.debasishg",
-    version := "2.15",
+    version := "3.0",
     scalaVersion := "2.11.6",
     crossScalaVersions := Seq("2.11.6", "2.10.4"),
 

diff --git a/src/main/scala/com/redis/RedisClient.scala b/src/main/scala/com/redis/RedisClient.scala
@@ -169,7 +169,7 @@ class RedisClient(override val host: String, override val port: Int,
     ps
   }
 
-  class PipelineClient(parent: RedisClient) extends RedisCommand {
+  class PipelineClient(parent: RedisClient) extends RedisCommand with PubOperations {
     import com.redis.serialization.Parse
 
     var handlers: Vector[() => Any] = Vector.empty

diff --git a/src/test/scala/com/redis/PipelineSpec.scala b/src/test/scala/com/redis/PipelineSpec.scala
@@ -35,6 +35,17 @@ class PipelineSpec extends FunSpec
     }
   }
 
+  describe("pipeline1 with publish") {
+    it("should do pipelined commands") {
+      r.pipeline { p =>
+        p.set("key", "debasish")
+        p.get("key")
+        p.get("key1")
+        p.publish("a", "debasish ghosh")
+      }.get should equal(List(true, Some("debasish"), None, Some(0)))
+    }
+  }
+
   describe("pipeline2") {
     it("should do pipelined commands") {
       r.pipeline { p =>