Fixed subscribing issue + converted Reader and Writer to trait + made host and port public

Author: Alexandre Curreli

build.sbt

@@ -6,7 +6,7 @@ organization := "com.livestream"
 
 name := "scredis"
 
-version := "2.0.5"
+version := "2.0.6"
 
 scalaVersion := "2.11.2"
 

src/main/scala/scredis/io/AbstractAkkaConnection.scala

@@ -15,8 +15,8 @@ import java.util.concurrent.{ CountDownLatch, TimeUnit }
 
 abstract class AbstractAkkaConnection(
   protected val system: ActorSystem,
-  protected val host: String,
-  protected val port: Int,
+  val host: String,
+  val port: Int,
   @volatile protected var passwordOpt: Option[String],
   @volatile protected var database: Int,
   @volatile protected var nameOpt: Option[String],

src/main/scala/scredis/io/SubscriberListenerActor.scala

@@ -111,11 +111,9 @@ class SubscriberListenerActor(
 
   override protected def always: Receive = super.always orElse {
     case Subscribe(subscription) => {
+      subscriptionOpt = Some(subscription)
       if (isInitialized) {
-        subscriptionOpt = Some(subscription)
         decoders.route(Broadcast(DecoderActor.Subscribe(subscription)), self)
-      } else {
-        previousSubscriptionOpt = Some(subscription)
       }
     }
     case Complete(message) => {

src/main/scala/scredis/serialization/Reader.scala

@@ -14,7 +14,7 @@ import java.nio.charset.StandardCharsets
  * @define e [[scredis.exceptions.RedisReaderException]]
  * 
  */
-abstract class Reader[A] {
+trait Reader[A] {
 
   /**
    * Internal read method to be implemented.

src/main/scala/scredis/serialization/Writer.scala

@@ -14,7 +14,7 @@ import java.nio.charset.StandardCharsets
  * @define e [[scredis.exceptions.RedisWriterException]]
  * 
  */
-abstract class Writer[-A] {
+trait Writer[A] {
 
   /**
    * Internal write method to be implemented.