class dataCapture(gr.sync_block):
    """
    docstring for block dataCapture
    """
    def __init__(self,IP="192.168.122.3",DataKind="RawTimeSamples",DataSource=0,Channel=0,size=1024,port=0):
      gr.sync_block.__init__(self,name="dataCapture",in_sig=None,out_sig=[numpy.float32])

      kind = 2
      if  (DataKind=="RawTimeSamples"):
        kind = 1
        self.size     = size
      elif(DataKind=="WindowingSamples"):
        kind = 2
        self.size     = size/2

      self.position = 0

      ### Capture packet
      self.DataSelection = namedtuple('DataSelection',['DataKind','DataSource','Channel','SizePc'])
      self.DataSelectionArray = []
      self.newObject = self.DataSelection(kind,DataSource,Channel,5)
      self.DataSelectionArray.append(self.newObject)

      ### Crear socket
      self.socketServer = serverCommander.authenticate(IP)


    def work(self, input_items, output_items):
      for i in range(0, len(output_items[0])):
        # rellenar
        if (self.position == 0):
          self.CaptureArray = serverCommander.captureData(self.socketServer[0],self.DataSelectionArray)

        output_items[0][i] = (self.CaptureArray[0].Data[self.subkind])[self.position]
        self.position = self.position + 1

        ## reiniciar
        if (self.position == self.size):
          self.position = 0

      return len(output_items[0])