()
| 257 | } |
| 258 | |
| 259 | func (s *Session) supportsMessageBatching() bool { |
| 260 | switch s.proto { |
| 261 | case WEBSOCK: |
| 262 | return true |
| 263 | case GRPC: |
| 264 | return true |
| 265 | default: |
| 266 | return false |
| 267 | } |
| 268 | } |
| 269 | |
| 270 | // queueOut attempts to send a list of ServerComMessages to a session write loop; |
| 271 | // it fails if the send buffer is full. |