It is also not safe to call CloseSend concurrently with SendMsg
()
| 108 | |
| 109 | // It is also not safe to call CloseSend concurrently with SendMsg |
| 110 | func (s safeWriteClient) CloseAndRecv() (*plugin.Write_Response, error) { |
| 111 | s.mu.Lock() |
| 112 | defer s.mu.Unlock() |
| 113 | return s.client.CloseAndRecv() |
| 114 | } |
| 115 | |
| 116 | func newSafeWriteClient(client grpc.ClientStreamingClient[plugin.Write_Request, plugin.Write_Response]) safeWriteClient { |
| 117 | return safeWriteClient{client: client, mu: &gosync.Mutex{}} |
no outgoing calls
no test coverage detected