@impl true
def handle_info(
{:ex_webrtc, pid, {:rtp, _track_id, _, rtp_packet}},
state
) do
Enum.each(state.peer_connections, fn
{_peer_id, %ConnectionInfo{connected: true, track_id: nil}} ->
Logger.warning("No track ID found for peer connection")
:ok
{_peer_id, %ConnectionInfo{connected: true, track_id: track_id} = connection_info} ->
PeerConnection.send_rtp(
connection_info.peer_connection,
connection_info.track_id,
rtp_packet
)
connection_info ->
:ok
end)
{:noreply, state}
end
@impl true
def handle_info(
{:ex_webrtc, pid, {:rtp, _track_id, _, rtp_packet}},
state
) do
Enum.each(state.peer_connections, fn
{_peer_id, %ConnectionInfo{connected: true, track_id: nil}} ->
Logger.warning("No track ID found for peer connection")
:ok
{_peer_id, %ConnectionInfo{connected: true, track_id: track_id} = connection_info} ->
PeerConnection.send_rtp(
connection_info.peer_connection,
connection_info.track_id,
rtp_packet
)
connection_info ->
:ok
end)
{:noreply, state}
end