stream

type Message struct {
	MsgType   string `json:"msg_type,omitempty"`
	Token     string `json:"token,omitempty"`
	Value     string `json:"value,omitempty"`
	Tag       string `json:"tag,omitempty"`
	ErrorType string `json:"error_type,omitempty"`
}

type StreamingError struct {
	Msg Message
}

type Subscriber struct {
	Data  chan interface{}
	Error chan error
	Close chan struct{}
}