class RageCableHelpers::MockWebSocketConnection

def close 

def close
  true
end

def initialize(env) 

def initialize(env)
  @env = env
  @messages = []
  @streams = []
end

def streams 

def streams
  @streams.uniq
end

def subscribe(stream) 

def subscribe(stream)
  @streams << stream.sub(/\Acable:/, "").sub(/:[0-9a-f]{32}\z/, "")
  true
end

def write(data) 

def write(data)
  @messages << data
  true
end