code: func (d *ManyToOne) Next() []byte {
  	data := d.d.Next()
  	return *(*[]byte)(data)
  }
docs: // Next will return the next item to be read from the diode. If the diode is
  // empty this method will block until an item is available to be read.