8000 Reformat & document permission shortcut on pre-M devices · model-lib/flutter-webrtc@e114a8a · GitHub
[go: up one dir, main page]
Skip to content

Commit e114a8a

Browse files
enedened
committed
Reformat & document permission shortcut on pre-M devices
1 parent c64d87c commit e114a8a

File tree

3 files changed

+1115
-1137
lines changed

3 files changed

+1115
-1137
lines changed

‎android/src/main/java/com/cloudwebrtc/webrtc/DataChannelObserver.java

Lines changed: 80 additions & 77 deletions
Original file line numberDiff line numberDiff line change
@@ -2,93 +2,96 @@
22

33
import com.cloudwebrtc.webrtc.utils.AnyThreadSink;
44
import com.cloudwebrtc.webrtc.utils.ConstraintsMap;
5+
6+
import org.webrtc.DataChannel;
7+
8+
import java.nio.charset.Charset;
9+
510
import io.flutter.plugin.common.BinaryMessenger;
611
import io.flutter.plugin.common.EventChannel;
7-
import java.nio.charset.Charset;
8-
import org.webrtc.DataChannel;
912

1013
class DataChannelObserver implements DataChannel.Observer, EventChannel.StreamHandler {
1114

12-
private final int mId;
13-
private final DataChannel mDataChannel;
14-
15-
private EventChannel eventChannel;
16-
private EventChannel.EventSink eventSink;
17-
18-
DataChannelObserver(BinaryMessenger messenger, String peerConnectionId, int id,
19-
DataChannel dataChannel) {
20-
mId = id;
21-
mDataChannel = dataChannel;
22-
eventChannel =
23-
new EventChannel(messenger, "FlutterWebRTC/dataChannelEvent" + peerConnectionId + id);
24-
eventChannel.setStreamHandler(this);
25-
}
26-
27-
private String dataChannelStateString(DataChannel.State dataChannelState) {
28-
switch (dataChannelState) {
29-
case CONNECTING:
30-
return "connecting";
31-
case OPEN:
32-
return "open";
33-
case CLOSING:
34-
return "closing";
35-
case CLOSED:
36-
return "closed";
15+
private final int mId;
16+
private final DataChannel mDataChannel;
17+
18+
private EventChannel eventChannel;
19+
private EventChannel.EventSink eventSink;
20+
21+
DataChannelObserver(BinaryMessenger messenger, String peerConnectionId, int id,
22+
DataChannel dataChannel) {
23+
mId = id;
24+
mDataChannel = dataChannel;
25+
eventChannel =
26+
new EventChannel(messenger, "FlutterWebRTC/dataChannelEvent" + peerConnectionId + id);
27+
eventChannel.setStreamHandler(this);
28+
}
29+
30+
private String dataChannelStateString(DataChannel.State dataChannelState) {
31+
switch (dataChannelState) {
32+
case CONNECTING:
33+
return "connecting";
34+
case OPEN:
35+
return "open";
36+
case CLOSING:
37+
return "closing";
38+
case CLOSED:
39+
return "closed";
40+
}
41+
return "";
42+
}
43+
44+
@Override
45+
public void onListen(Object o, EventChannel.EventSink sink) {
46+
eventSink = new AnyThreadSink(sink);
47+
}
48+
49+
@Override
50+
public void onCancel(Object o) {
51+
eventSink = null;
3752
}
38-
return "";
39-
}
40-
41-
@Override
42-
public void onListen(Object o, EventChannel.EventSink sink) {
43-
eventSink = new AnyThreadSink(sink);
44-
}
45-
46-
@Override
47-
public void onCancel(Object o) {
48-
eventSink = null;
49-
}
50-
51-
@Override
52-
public void onBufferedAmountChange(long amount) {
53-
}
54-
55-
@Override
56-
public void onStateChange() {
57-
ConstraintsMap params = new ConstraintsMap();
58-
params.putString("event", "dataChannelStateChanged");
59-
params.putInt("id", mDataChannel.id());
60-
params.putString("state", dataChannelStateString(mDataChannel.state()));
61-
sendEvent(params);
62-
}
63-
64-
@Override
65-
public void onMessage(DataChannel.Buffer buffer) {
66-
ConstraintsMap params = new ConstraintsMap();
67-
params.putString("event", "dataChannelReceiveMessage");
68-
params.putInt("id", mDataChannel.id());
69-
70-
byte[] bytes;
71-
if (buffer.data.hasArray()) {
72-
bytes = buffer.data.array();
73-
} else {
74-
bytes = new byte[buffer.data.remaining()];
75-
buffer.data.get(bytes);
53+
54+
@Override
55+
public void onBufferedAmountChange(long amount) {
7656
}
7757

78-
if (buffer.binary) {
79-
params.putString("type", "binary");
80-
params.putByte("data", bytes);
81-
} else {
82-
params.putString("type", "text");
83-
params.putString("data", new String(bytes, Charset.forName("UTF-8")));
58+
@Override
59+
public void onStateChange() {
60+
ConstraintsMap params = new ConstraintsMap();
61+
params.putString("event", "dataChannelStateChanged");
62+
params.putInt("id", mDataChannel.id());
63+
params.putString("state", dataChannelStateString(mDataChannel.state()));
64+
sendEvent(params);
8465
}
8566

86-
sendEvent(params);
87-
}
67+
@Override
68+
public void onMessage(DataChannel.Buffer buffer) {
69+
ConstraintsMap params = new ConstraintsMap();
70+
params.putString("event", "dataChannelReceiveMessage");
71+
params.putInt("id", mDataChannel.id());
72+
73+
byte[] bytes;
74+
if (buffer.data.hasArray()) {
75+
bytes = buffer.data.array();
76+
} else {
77+
bytes = new byte[buffer.data.remaining()];
78+
buffer.data.get(bytes);
79+
}
80+
81+
if (buffer.binary) {
82+
params.putString("type", "binary");
83+
params.putByte("data", bytes);
84+
} else {
85+
params.putString("type", "text");
86+
params.putString("data", new String(bytes, Charset.forName("UTF-8")));
87+
}
88+
89+
sendEvent(params);
90+
}
8891

89-
private void sendEvent(ConstraintsMap params) {
90-
if (eventSink != null) {
91-
eventSink.success(params.toMap());
92+
private void sendEvent(ConstraintsMap params) {
93+
if (eventSink != null) {
94+
eventSink.success(params.toMap());
95+
}
9296
}
93-
}
9497
}

0 commit comments

Comments
 (0)
0