patch bug in worker

Former-commit-id: f83cc62fc7a85f732e871f8866f80f738f494f9e

pkg/obiiter/batchiterator.go

@@ -427,14 +427,20 @@ func (iterator IBioSequence) Rebatch(size int) IBioSequence {
 
 		for iterator.Next() {
 			seqs := iterator.Get()
-			// log.Println("Got seq #", len(seqs.Slice()))
+			lc := seqs.Len()
-			for _, s := range seqs.slice {
+			remains := lc
-				buffer = append(buffer, s)
+			i := 0
+			for remains > 0 {
+				space := size - len(buffer)
+				to_push := min(lc-i, space)
+				remains = lc - to_push - i
+				buffer = append(buffer, seqs.Slice()[i:(i+to_push)]...)
 				if len(buffer) == size {
 					newIter.Push(MakeBioSequenceBatch(order, buffer))
 					order++
 					buffer = obiseq.MakeBioSequenceSlice()
 				}
+				i += to_push
 			}
 			seqs.Recycle(false)
 		}

pkg/obiiter/workers.go

@@ -140,11 +140,7 @@ func (iterator IBioSequence) MakeISliceWorker(worker obiseq.SeqSliceWorker, size
 		for iterator.Next() {
 			batch := iterator.Get()
 			batch.slice = worker(batch.slice)
-			if batch.slice.Len() > 0 {
+			newIter.Push(batch)
-				newIter.Push(batch)
-			} else {
-				batch.Recycle(false)
-			}
 		}
 		newIter.Done()
 	}