| 123456789101112131415161718192021222324252627282930313233343536373839 |
- extends Node
- # An example p2p chat client.
- var peer = WebRTCPeerConnection.new()
- # Create negotiated data channel.
- var channel = peer.create_data_channel("chat", {"negotiated": true, "id": 1})
- func _ready():
- # Connect all functions.
- peer.ice_candidate_created.connect(self._on_ice_candidate)
- peer.session_description_created.connect(self._on_session)
- # Register to the local signaling server (see below for the implementation).
- Signaling.register(String(get_path()))
- func _on_ice_candidate(mid, index, sdp):
- # Send the ICE candidate to the other peer via signaling server.
- Signaling.send_candidate(String(get_path()), mid, index, sdp)
- func _on_session(type, sdp):
- # Send the session to other peer via signaling server.
- Signaling.send_session(String(get_path()), type, sdp)
- # Set generated description as local.
- peer.set_local_description(type, sdp)
- func _process(delta):
- # Always poll the connection frequently.
- peer.poll()
- if channel.get_ready_state() == WebRTCDataChannel.STATE_OPEN:
- while channel.get_available_packet_count() > 0:
- print(String(get_path()), " received: ", channel.get_packet().get_string_from_utf8())
- func send_message(message):
- channel.put_packet(message.to_utf8_buffer())
|
