diff --git a/cpp/core/internal/mediums/webrtc/webrtc_socket.cc b/cpp/core/internal/mediums/webrtc/webrtc_socket.cc index 159cfaed..ff7f1f18 100644 --- a/cpp/core/internal/mediums/webrtc/webrtc_socket.cc +++ b/cpp/core/internal/mediums/webrtc/webrtc_socket.cc @@ -49,9 +49,8 @@ InputStream& WebRtcSocket::GetInputStream() { return pipe_.GetInputStream(); } OutputStream& WebRtcSocket::GetOutputStream() { return output_stream_; } void WebRtcSocket::Close() { - if (IsClosed()) return; + if (closed_.Set(true)) return; - closed_.Set(true); pipe_.GetInputStream().Close(); pipe_.GetOutputStream().Close(); data_channel_->Close();