Fix bug in posts stream

This commits fixes an issue where posts would still appear
even if they had already been fetched when using the DiscardInitial
option.

reddit/stream.go

@@ -2,6 +2,7 @@ package reddit
 
 import (
 	"context"
+	"fmt"
 	"sync"
 	"time"
 )
@@ -72,15 +73,19 @@ func (s *StreamService) Posts(subreddit string, opts ...StreamOpt) (<-chan *Post
 					break
 				}
 				ids.Add(id)
+				fmt.Printf("stream: id: %s\n", id)
 
+				// skip this post because we are discarding initial fetch of posts
 				if streamConfig.DiscardInitial {
-					streamConfig.DiscardInitial = false
-					break
+					continue
 				}
 
 				postsCh <- post
 			}
 
+			// setting discard initial to false, since we the loop has run once already
+			streamConfig.DiscardInitial = false
+
 			if !infinite && n >= streamConfig.MaxRequests {
 				break
 			}