Method RecvMsg

modules/frontend/search_handlers_test.go:110–110

(interface{})

func (m *mockGRPCStreaming[T]) SetHeader(metadata.MD) error  { return nil }
func (m *mockGRPCStreaming[T]) SendMsg(interface{}) error    { return nil }
func (m *mockGRPCStreaming[T]) RecvMsg(interface{}) error    { return nil }
func (m *mockGRPCStreaming[T]) SetTrailer(metadata.MD)       {}

func newMockStreamingServer[T proto.Message](orgID string, cb func(int, T)) *mockGRPCStreaming[T] {