func (_m *MockWSConnector) AcceptPublisherStream(w http.ResponseWriter, r *http.Request) (serverStream.BInOpenPublisherStreamInCall, error) {
	ret := _m.Called(w, r)
	var r0 serverStream.BInOpenPublisherStreamInCall
	if rf, ok := ret.Get(0).(func(http.ResponseWriter, *http.Request) serverStream.BInOpenPublisherStreamInCall); ok {
		r0 = rf(w, r)
	} else {
		r0 = ret.Get(0).(serverStream.BInOpenPublisherStreamInCall)
	}
	var r1 error
	if rf, ok := ret.Get(1).(func(http.ResponseWriter, *http.Request) error); ok {
		r1 = rf(w, r)
	} else {
		r1 = ret.Error(1)
	}
	return r0, r1
}
AcceptPublisherStream is the mock for corresponding method on WSConnector
package common
import "github.com/stretchr/testify/mock"
import "net/http"
import serverStream "github.com/uber/cherami-server/stream"
import clientStream "github.com/uber/cherami-client-go/stream"
type MockWSConnector struct {
	mock.Mock
}
func (_m *MockWSConnector) OpenPublisherStream(hostPort string, requestHeader http.Header) (clientStream.BInOpenPublisherStreamOutCall, error) {
	ret := _m.Called(hostPort, requestHeader)
	var r0 clientStream.BInOpenPublisherStreamOutCall
	if rf, ok := ret.Get(0).(func(string, http.Header) clientStream.BInOpenPublisherStreamOutCall); ok {
		r0 = rf(hostPort, requestHeader)
	} else {
		r0 = ret.Get(0).(clientStream.BInOpenPublisherStreamOutCall)
	}
	var r1 error
	if rf, ok := ret.Get(1).(func(string, http.Header) error); ok {
		r1 = rf(hostPort, requestHeader)
	} else {
		r1 = ret.Error(1)
	}
	return r0, r1
}