code: def realTest(self, N, M):
      inputs = []
      expected = []
      for n in range(N):
          inputs.append([float(i) for i in range(n * M, (n + 1) * M)])
  
      for m in range(M):
          expected.append(range(m, N * M, M))
  
      gens = [VectorInput(input) for input in inputs]
      mux = Multiplexer(numberRealInputs=N)
      ports = []
      for i in range(N):
          ports.append(getattr(mux, "real_" + str(i)))
          gens[i].data >> ports[i]
  
      pool = Pool()
      mux.data >> (pool, "real")
      for gen in gens:
          run(gen)
  
      if not N or not M:
          self.assertEqual(pool.descriptorNames(), [])
          return
  
      self.assertEqualMatrix(pool["real"], expected)
  
file_path: essentia/test/src/unittests/standard/test_multiplexer_streaming.py
imports: from essentia_test import *
  from essentia.streaming import Multiplexer
label_desc: Use image node_id 1 for calling the TestMultiplexer_Streaming obj's underlying member method code with example usage: obj.realTest(N, M) without return types