krak3n

func (p *PerceptorService) Run() {
	for {
		conn, _, err := d.Dial(host, headers)
		if err != nil {
			fmt.Printf("WS Connection Failure: %s", err)
			time.Sleep(time.Second)
			continue
		}
	ReadLoop:
		for {

krak3n

package main

import (
	"bufio"
	"bytes"
	"encoding/json"
	"fmt"
	"io"
	"os"
)

krak3n

package main

import (
	"bufio"
	"bytes"
	"io/ioutil"
	"path/filepath"
	"testing"
)

krak3n

package main

import (
	"bufio"
	"bytes"
	"flag"
	"io/ioutil"
	"path/filepath"
	"testing"
)

krak3n

package main

import (
	"bufio"
	"bytes"
	"flag"
	"io/ioutil"
	"path/filepath"
	"testing"
)

krak3n

type TestSetter struct {
	cmd *redis.StatusCmd
}

func (t *TestSetter) Set(k string, v interface{}, d time.Duration) *redis.StatusCmd {
	return t.cmd
}

// Unit - make it fail
func Test_setUser(t *testing.T) {