File tree Expand file tree Collapse file tree 1 file changed +10
-16
lines changed Expand file tree Collapse file tree 1 file changed +10
-16
lines changed Original file line number Diff line number Diff line change @@ -262,23 +262,17 @@ func (wsc *wsMinioClient) objectManager(session *models.Principal) {
262262
263263 defer close (done )
264264
265- for {
266- select {
267- case writeM , ok := <- writeChannel :
268- if ! ok {
269- return
270- }
271- jsonData , err := json .Marshal (writeM )
272- if err != nil {
273- LogInfo ("Error while marshaling the response" , err )
274- return
275- }
265+ for writeM := range writeChannel {
266+ jsonData , err := json .Marshal (writeM )
267+ if err != nil {
268+ LogInfo ("Error while marshaling the response" , err )
269+ return
270+ }
276271
277- err = wsc .conn .writeMessage (websocket .TextMessage , jsonData )
278- if err != nil {
279- LogInfo ("Error while writing the message" , err )
280- return
281- }
272+ err = wsc .conn .writeMessage (websocket .TextMessage , jsonData )
273+ if err != nil {
274+ LogInfo ("Error while writing the message" , err )
275+ return
282276 }
283277 }
284278}
You can’t perform that action at this time.
0 commit comments