From e271067b730add330566aa1f65fdae00a5a40b66 Mon Sep 17 00:00:00 2001 From: Bill Burdick Date: Tue, 9 Nov 2010 10:47:42 +0200 Subject: [PATCH] a bit of cleanup --- seq/seq.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/seq/seq.go b/seq/seq.go index e5dbd53..e578449 100644 --- a/seq/seq.go +++ b/seq/seq.go @@ -247,15 +247,11 @@ func CMap(s Seq, f func(el El) El, sizeOpt... int) Seq { go func(){ window := NewSlidingWindow(size) replyChannel := make(chan reply) - inputCount := 0 - pendingInput := 0 - pendingOutput := 0 + inputCount, pendingInput, pendingOutput := 0, 0, 0 inputClosed := false for { first, hasFirst := window.GetFirst() - oc := output - ic := input - rc :- replyChannel + ic, oc, rc := input, output, replyChannel if !hasFirst {oc = nil} if inputClosed || pendingInput >= size {ic = nil} if pendingOutput >= size {rc = nil} -- 2.11.4.GIT