This commit is contained in:
Marks Polakovs 2020-04-12 22:19:13 +02:00
parent c1dd57eabf
commit 517c874e51

View file

@ -124,6 +124,7 @@ class Session(object):
self.websocket = None self.websocket = None
self.sender = None self.sender = None
self.pc = None self.pc = None
self.resampler = None
self.connection_state = None self.connection_state = None
self.connection_id = str(uuid.uuid4()) self.connection_id = str(uuid.uuid4())
self.ended = False self.ended = False
@ -235,7 +236,6 @@ class Session(object):
transfer_buffer1.write(new_frame.planes[0]) transfer_buffer1.write(new_frame.planes[0])
transfer_buffer2.write(new_frame.planes[1]) transfer_buffer2.write(new_frame.planes[1])
async def process_ice(self, message: Any) -> None: async def process_ice(self, message: Any) -> None:
if self.connection_state == "HELLO" and message["kind"] == "OFFER": if self.connection_state == "HELLO" and message["kind"] == "OFFER":
offer = RTCSessionDescription(sdp=message["sdp"], type=message["type"]) offer = RTCSessionDescription(sdp=message["sdp"], type=message["type"])