Add channel.ignoreReads()

channel.go

@@ -18,6 +18,8 @@ type Channel struct {
 	logger *logrus.Entry
 	confCh chan bool
 	readCh chan *cableMsg
+
+	ignoreReads bool
 }
 
 // Perform sends passed action with additional data to the channel
@@ -37,6 +39,11 @@ func (ch *Channel) Perform(action string, attr goja.Value) error {
 	})
 }
 
+// IgnoreReads allows skipping collecting incoming messages (in case you only care about the subscription)
+func (ch *Channel) IgnoreReads() {
+	ch.ignoreReads = true
+}
+
 // Receive checks channels messages query for message, sugar for ReceiveN(1, attrs)
 func (ch *Channel) Receive(attr goja.Value) interface{} {
 	results := ch.ReceiveN(1, attr)
@@ -78,6 +85,14 @@ func (ch *Channel) ReceiveN(n int, cond goja.Value) []interface{} {
 	}
 }
 
+func (ch *Channel) handleIncoming(msg *cableMsg) {
+	if ch.ignoreReads {
+		return
+	}
+
+	ch.readCh <- msg
+}
+
 type Matcher interface {
 	Match(msg interface{}) bool
 }

client.go

@@ -131,7 +131,7 @@ func (c *Client) handleLoop() {
 				case "reject_subscription":
 					c.channels[msg.Identifier].confCh <- false
 				default:
-					c.channels[msg.Identifier].readCh <- msg
+					c.channels[msg.Identifier].handleIncoming(msg)
 				}
 			}
 		case err := <-c.errorCh: