func (mr *MockPubSub_SubscribeClientMockRecorder) CloseSend() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CloseSend", reflect.TypeOf((*MockPubSub_SubscribeClient)(nil).CloseSend))
}
CloseSend indicates an expected call of CloseSend
package mock_proto
import (
	context "context"
	reflect "reflect"
	gomock "github.com/golang/mock/gomock"
	empty "github.com/golang/protobuf/ptypes/empty"
	proto "github.com/vardius/pubsub/v2/proto"
	grpc "google.golang.org/grpc"
	metadata "google.golang.org/grpc/metadata"
)
type MockPubSubClient struct {
	ctrl     *gomock.Controller
	recorder *MockPubSubClientMockRecorder
}
type MockPubSubClientMockRecorder struct {
	mock *MockPubSubClient
}
func NewMockPubSubClient(ctrl *gomock.Controller) *MockPubSubClient {
	mock := &MockPubSubClient{ctrl: ctrl}
	mock.recorder = &MockPubSubClientMockRecorder{mock}
	return mock
}
func (m *MockPubSubClient) EXPECT() *MockPubSubClientMockRecorder {
	return m.recorder
}
func (m *MockPubSubClient) Publish(ctx context.Context, in *proto.PublishRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
	m.ctrl.T.Helper()
	varargs := []interface{}{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "Publish", varargs...)
	ret0, _ := ret[0].(*empty.Empty)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}
func (mr *MockPubSubClientMockRecorder) Publish(ctx, in interface{}, opts ...interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]interface{}{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Publish", reflect.TypeOf((*MockPubSubClient)(nil).Publish), varargs...)
}
func (m *MockPubSubClient) Subscribe(ctx context.Context, in *proto.SubscribeRequest, opts ...grpc.CallOption) (proto.PubSub_SubscribeClient, error) {
	m.ctrl.T.Helper()
	varargs := []interface{}{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "Subscribe", varargs...)
	ret0, _ := ret[0].(proto.PubSub_SubscribeClient)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}
func (mr *MockPubSubClientMockRecorder) Subscribe(ctx, in interface{}, opts ...interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]interface{}{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Subscribe", reflect.TypeOf((*MockPubSubClient)(nil).Subscribe), varargs...)
}
type MockPubSub_SubscribeClient struct {
	ctrl     *gomock.Controller
	recorder *MockPubSub_SubscribeClientMockRecorder
}
type MockPubSub_SubscribeClientMockRecorder struct {
	mock *MockPubSub_SubscribeClient
}
func NewMockPubSub_SubscribeClient(ctrl *gomock.Controller) *MockPubSub_SubscribeClient {
	mock := &MockPubSub_SubscribeClient{ctrl: ctrl}
	mock.recorder = &MockPubSub_SubscribeClientMockRecorder{mock}
	return mock
}
func (m *MockPubSub_SubscribeClient) EXPECT() *MockPubSub_SubscribeClientMockRecorder {
	return m.recorder
}
func (m *MockPubSub_SubscribeClient) Recv() (*proto.SubscribeResponse, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "Recv")
	ret0, _ := ret[0].(*proto.SubscribeResponse)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}
func (mr *MockPubSub_SubscribeClientMockRecorder) Recv() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Recv", reflect.TypeOf((*MockPubSub_SubscribeClient)(nil).Recv))
}
func (m *MockPubSub_SubscribeClient) Header() (metadata.MD, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "Header")
	ret0, _ := ret[0].(metadata.MD)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}
func (mr *MockPubSub_SubscribeClientMockRecorder) Header() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Header", reflect.TypeOf((*MockPubSub_SubscribeClient)(nil).Header))
}
func (m *MockPubSub_SubscribeClient) Trailer() metadata.MD {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "Trailer")
	ret0, _ := ret[0].(metadata.MD)
	return ret0
}
func (mr *MockPubSub_SubscribeClientMockRecorder) Trailer() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Trailer", reflect.TypeOf((*MockPubSub_SubscribeClient)(nil).Trailer))
}
func (m *MockPubSub_SubscribeClient) CloseSend() error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "CloseSend")
	ret0, _ := ret[0].(error)
	return ret0
}