/*
 * Copyright 2022 CloudWeGo Authors
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
*/


// Code generated by MockGen. DO NOT EDIT.
// Source: ../../pkg/remote/trans_meta.go

// Package remote is a generated GoMock package.
package remote

import (
	context "context"
	reflect "reflect"

	remote "github.com/cloudwego/kitex/pkg/remote"
	gomock "github.com/golang/mock/gomock"
)

// MockMetaHandler is a mock of MetaHandler interface.
type MockMetaHandler struct {
	ctrl     *gomock.Controller
	recorder *MockMetaHandlerMockRecorder
}

// MockMetaHandlerMockRecorder is the mock recorder for MockMetaHandler.
type MockMetaHandlerMockRecorder struct {
	mock *MockMetaHandler
}

// NewMockMetaHandler creates a new mock instance.
func NewMockMetaHandler(ctrl *gomock.Controller) *MockMetaHandler {
	mock := &MockMetaHandler{ctrl: ctrl}
	mock.recorder = &MockMetaHandlerMockRecorder{mock}
	return mock
}

// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockMetaHandler) EXPECT() *MockMetaHandlerMockRecorder {
	return m.recorder
}

// ReadMeta mocks base method.
func (m *MockMetaHandler) ReadMeta(ctx context.Context, msg remote.Message) (context.Context, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ReadMeta", ctx, msg)
	ret0, _ := ret[0].(context.Context)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ReadMeta indicates an expected call of ReadMeta.
func (mr *MockMetaHandlerMockRecorder) ReadMeta(ctx, msg interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ReadMeta", reflect.TypeOf((*MockMetaHandler)(nil).ReadMeta), ctx, msg)
}

// WriteMeta mocks base method.
func (m *MockMetaHandler) WriteMeta(ctx context.Context, msg remote.Message) (context.Context, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "WriteMeta", ctx, msg)
	ret0, _ := ret[0].(context.Context)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// WriteMeta indicates an expected call of WriteMeta.
func (mr *MockMetaHandlerMockRecorder) WriteMeta(ctx, msg interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "WriteMeta", reflect.TypeOf((*MockMetaHandler)(nil).WriteMeta), ctx, msg)
}

// MockStreamingMetaHandler is a mock of StreamingMetaHandler interface.
type MockStreamingMetaHandler struct {
	ctrl     *gomock.Controller
	recorder *MockStreamingMetaHandlerMockRecorder
}

// MockStreamingMetaHandlerMockRecorder is the mock recorder for MockStreamingMetaHandler.
type MockStreamingMetaHandlerMockRecorder struct {
	mock *MockStreamingMetaHandler
}

// NewMockStreamingMetaHandler creates a new mock instance.
func NewMockStreamingMetaHandler(ctrl *gomock.Controller) *MockStreamingMetaHandler {
	mock := &MockStreamingMetaHandler{ctrl: ctrl}
	mock.recorder = &MockStreamingMetaHandlerMockRecorder{mock}
	return mock
}

// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockStreamingMetaHandler) EXPECT() *MockStreamingMetaHandlerMockRecorder {
	return m.recorder
}

// OnConnectStream mocks base method.
func (m *MockStreamingMetaHandler) OnConnectStream(ctx context.Context) (context.Context, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "OnConnectStream", ctx)
	ret0, _ := ret[0].(context.Context)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// OnConnectStream indicates an expected call of OnConnectStream.
func (mr *MockStreamingMetaHandlerMockRecorder) OnConnectStream(ctx interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "OnConnectStream", reflect.TypeOf((*MockStreamingMetaHandler)(nil).OnConnectStream), ctx)
}

// OnReadStream mocks base method.
func (m *MockStreamingMetaHandler) OnReadStream(ctx context.Context) (context.Context, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "OnReadStream", ctx)
	ret0, _ := ret[0].(context.Context)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// OnReadStream indicates an expected call of OnReadStream.
func (mr *MockStreamingMetaHandlerMockRecorder) OnReadStream(ctx interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "OnReadStream", reflect.TypeOf((*MockStreamingMetaHandler)(nil).OnReadStream), ctx)
}
