func (m *MockBOutOpenConsumerStreamInCall) Done() error {
	return m.Called().Error(0)
}
Done is a mock of the corresponding cherami. routinee
package outputhost
import (
	"github.com/uber/cherami-thrift/.generated/go/cherami"
	"github.com/stretchr/testify/mock"
)
type MockBOutOpenConsumerStreamInCall struct {
	mock.Mock
}
func (m *MockBOutOpenConsumerStreamInCall) Write(msg *cherami.OutputHostCommand) error {
	args := m.Called(msg)
	return args.Error(0)
}
func (m *MockBOutOpenConsumerStreamInCall) Flush() error {
	return m.Called().Error(0)
}