func (m *MockBStoreOpenReadStreamOutCallForReplicator) Write(msg *cherami.ControlFlow) error {
	args := m.Called(msg)
	return args.Error(0)
}
Write is the mock of the corresponding store. method
package replicator
import (
	"github.com/uber/cherami-thrift/.generated/go/cherami"
	"github.com/uber/cherami-thrift/.generated/go/store"
	"github.com/stretchr/testify/mock"
)
type MockBStoreOpenReadStreamOutCallForReplicator struct {
	mock.Mock
}