8000 Add streaming API for datachannel messages and state changes. by FrobtheBuilder · Pull Request #91 · flutter-webrtc/flutter-webrtc · GitHub
[go: up one dir, main page]
Skip to content

Add streaming API for datachannel messages and state changes. #91

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom
Merged
merged 4 commits into from
May 15, 2019
Merged

Add streaming API for datachannel messages and state changes. #91

merged 4 commits into from
May 15, 2019

Conversation

FrobtheBuilder
Copy link
Contributor
@FrobtheBuilder FrobtheBuilder commented May 14, 2019 •
edited
Loading

This change adds a streaming API to the RTCDataChannel. Adds stateChangeStream and messageStream to the RTCDataChannel class, which are broadcast streams that emit state changes and messages, just as would be passed to the onDataChannelState and onMessage handlers. This allows for easily attaching multiple listeners to these events, whereas previously the class could only support one handler for each.

Adds functionality from my own wrapper utility class:

class StreamingRTCDataChannel {
  RTCDataChannel dataChannel;
  final _messageController = StreamController<RTCDataChannelMessage>.broadcast();
  final _stateChangeController = StreamController<RTCDataChannelState>.broadcast();
  Stream<RTCDataChannelMessage> message;
  Stream<RTCDataChannelState> stateChange;
  StreamingRTCDataChannel(this.dataChannel) {
    message = _messageController.stream;
    stateChange = _stateChangeController.stream;
    dataChannel.onMessage = _messageController.add;
    dataChannel.onDataChannelState = _stateChangeController.add;
  }
}

Which will no longer be necessary after this change.

Also updates the datachannel example code to show usage.

This change has been tested within our own app and will not break the existing API, as it's only adding new properties to the class. It should not cause any performance issues, since broadcast streams don't buffer their events and only deliver them to active listeners on demand. If nothing is listening, events are simply discarded.

@FrobtheBuilder
Copy link
Contributor Author
FrobtheBuilder commented May 14, 2019 •
edited
Loading

It might be a good idea to use the SynchronousStreamController instead since the events are already asynchronous. It improves latency, but it DOES break the stream contract. That shouldn't be an issue though since add is just being called in an async listener itself. Tell me what you think.

@FrobtheBuilder
Copy link
Contributor Author
FrobtheBuilder commented May 14, 2019 •
edited
Loading

I decided to just go ahead and do it. Should improve performance. Just tell me if you think there's some reason it shouldn't work that way. It should behave exactly as expected since add is the last thing being done in the async listener, and it works perfectly fine in testing.
https://api.dartlang.org/stable/2.3.0/dart-async/SynchronousStreamController-class.html

@cloudwebrtc cloudwebrtc merged commit d25ce9a into flutter-webrtc:master May 15, 2019
cloudwebrtc added a commit that referenced this pull request Jul 4, 2020
@cloudwebrtc
Merge pull request #91 from RainwayApp/streaming-datachannel
3622341 
Add streaming API for datachannel messages and state changes.
evdokimovs pushed a commit to evdokimovs/flutter-webrtc that referenced this pull request Jun 6, 2024
@rogurotus @alexlapa
Implement getStats() for Android platform (flutter-webrtc#91)
f8ba64f 
Co-authored-by: alexlapa <lapa.alex@ex.ua>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers
No reviews
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.
2 participants
@FrobtheBuilder @cloudwebrtc
0