func (st *state) ConnectStream(path string, attrs url.Values) (base.Stream, error) {
	path, err := apiPath(st.modelTag, path)
	if err != nil {
		return nil, errors.Trace(err)
	}
	conn, err := st.connectStreamWithRetry(path, attrs, nil)
	if err != nil {
		return nil, errors.Trace(err)
	}
	return conn, nil
}
// ConnectStream implements StreamConnector.ConnectStream. The stream
// returned will apply a 30-second write deadline, so WriteJSON should
// only be called from one goroutine.
ConnectStream implements StreamConnector.ConnectStream. The stream
returned will apply a 30-second write deadline, so WriteJSON should
only be called from one goroutine.
// ConnectStream implements StreamConnector . ConnectStream . The stream // returned will apply a 30 - second write deadline so WriteJSON should // only be called from one goroutine .
func (st *state) ConnectStream(path string, attrs url.Values) (base.Stream, error) {
	path, err := apiPath(st.modelTag, path)
	if err != nil {
		return nil, errors.Trace(err)
	}
	conn, err := st.connectStreamWithRetry(path, attrs, nil)
	if err != nil {
		return nil, errors.Trace(err)
	}
	return conn, nil
}
func ( st * state ) ConnectStream ( path string , attrs url . Values ) ( base . Stream , error ) { path , err := apiPath ( st . modelTag , path ) if err != nil { return nil , errors . Trace ( err ) } conn , err := st . connectStreamWithRetry ( path , attrs , nil ) if err != nil { return nil , errors . Trace ( err ) } return conn , nil }
ConnectStream implements StreamConnector.ConnectStream.
ConnectStream implements StreamConnector . ConnectStream .