handle close

Author: Gsantomaggio

pkg/stream/coordinator.go

@@ -59,7 +59,7 @@ func (coordinator *Coordinator) NewProducer(
 		status:              open,
 		messageSequenceCh:   make(chan messageSequence, size),
 		pendingMessages: pendingMessagesSequence{
-			messages: make([]messageSequence, 0),
+			messages: make([]messageSequence, 1),
 			size:     initBufferPublishSize,
 		}}
 	coordinator.producers[lastId] = producer