Merge pull request #39 from openfresh/feature/spread_channel

spread channel capacity
opensaasstudio · Jun 5, 2017 · d7ee1d9 · d7ee1d9
2 parents c32a298 + c8775d5
commit d7ee1d9
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/manager/client.go b/manager/client.go
@@ -23,7 +23,7 @@ func (c *Client) SetEvents(events []string) {
 func NewClient(events []string) Client {
 	return Client{
 		events:      events,
-		payloadChan: make(chan event.Payload),
+		payloadChan: make(chan event.Payload, 20),
 	}
 }
 

diff --git a/server/grpc.go b/server/grpc.go
@@ -85,12 +85,12 @@ type StreamServer struct {
 func NewStreamServer(opt Option) *StreamServer {
 	ss := &StreamServer{
 		clientManager:  manager.NewClientManager(),
-		newClients:     make(chan manager.Client),
-		removeClients:  make(chan manager.Client),
-		payloads:       make(chan event.Payload),
-		errChan:        make(chan error),
-		forceCloseChan: make(chan manager.Client),
-		resfreshEvents: make(chan refreshEvents),
+		newClients:     make(chan manager.Client, 20),
+		removeClients:  make(chan manager.Client, 20),
+		payloads:       make(chan event.Payload, 20),
+		errChan:        make(chan error, 20),
+		forceCloseChan: make(chan manager.Client, 20),
+		resfreshEvents: make(chan refreshEvents, 20),
 		pubsub:         opt.PubSuber,
 		accessLogger:   opt.AccessLogger,
 		errorLogger:    opt.ErrorLogger,