From 6f19875d32503d731a7911e6a31206283c87ec89 Mon Sep 17 00:00:00 2001 From: Gregory Eremin Date: Mon, 23 Feb 2015 20:09:36 +0700 Subject: [PATCH] Buffer stream rewrite --- buffer/buffer.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/buffer/buffer.go b/buffer/buffer.go index b9c74fa..30745c3 100644 --- a/buffer/buffer.go +++ b/buffer/buffer.go @@ -39,12 +39,12 @@ func (b *Buffer) Next() rune { } func (b *Buffer) stream() { + defer close(b.ready) for { - if r, _, err := b.input.ReadRune(); err != nil { - close(b.ready) - break - } else { + if r, _, err := b.input.ReadRune(); err == nil { b.ready <- r + } else { + return } } }