Skip to content

Commit 01b7f8f

Browse files
committed
restore missing PlaybackSampleAdapter
1 parent 25b7a96 commit 01b7f8f

File tree

2 files changed

+29
-29
lines changed

2 files changed

+29
-29
lines changed

android/src/main/java/io/getstream/webrtc/flutter/MethodCallHandlerImpl.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929
import io.getstream.webrtc.flutter.audio.AudioFocusManager;
3030
import io.getstream.webrtc.flutter.audio.AudioUtils;
3131
import io.getstream.webrtc.flutter.audio.LocalAudioTrack;
32-
// import io.getstream.webrtc.flutter.audio.PlaybackSamplesReadyCallbackAdapter;
32+
import io.getstream.webrtc.flutter.audio.PlaybackSamplesReadyCallbackAdapter;
3333
import io.getstream.webrtc.flutter.audio.RecordSamplesReadyCallbackAdapter;
3434
import io.getstream.webrtc.flutter.record.AudioChannel;
3535
import io.getstream.webrtc.flutter.record.FrameCapturer;
@@ -119,7 +119,7 @@ public class MethodCallHandlerImpl implements MethodCallHandler, StateProvider {
119119

120120
public RecordSamplesReadyCallbackAdapter recordSamplesReadyCallbackAdapter;
121121

122-
// public PlaybackSamplesReadyCallbackAdapter playbackSamplesReadyCallbackAdapter;
122+
public PlaybackSamplesReadyCallbackAdapter playbackSamplesReadyCallbackAdapter;
123123

124124
/**
125125
* The implementation of {@code getUserMedia} extracted into a separate file in order to reduce
@@ -238,7 +238,7 @@ private void initialize(boolean bypassVoiceProcessing, int networkIgnoreMask, bo
238238
JavaAudioDeviceModule.Builder audioDeviceModuleBuilder = JavaAudioDeviceModule.builder(context);
239239

240240
recordSamplesReadyCallbackAdapter = new RecordSamplesReadyCallbackAdapter();
241-
// playbackSamplesReadyCallbackAdapter = new PlaybackSamplesReadyCallbackAdapter();
241+
playbackSamplesReadyCallbackAdapter = new PlaybackSamplesReadyCallbackAdapter();
242242

243243
if(bypassVoiceProcessing) {
244244
audioDeviceModuleBuilder.setUseHardwareAcousticEchoCanceler(false)
@@ -255,7 +255,7 @@ private void initialize(boolean bypassVoiceProcessing, int networkIgnoreMask, bo
255255
}
256256

257257
audioDeviceModuleBuilder.setSamplesReadyCallback(recordSamplesReadyCallbackAdapter);
258-
// audioDeviceModuleBuilder.setPlaybackSamplesReadyCallback(playbackSamplesReadyCallbackAdapter);
258+
audioDeviceModuleBuilder.setPlaybackSamplesReadyCallback(playbackSamplesReadyCallbackAdapter);
259259

260260
recordSamplesReadyCallbackAdapter.addCallback(getUserMediaImpl.inputSamplesInterceptor);
261261

Lines changed: 25 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -1,32 +1,32 @@
1-
// package io.getstream.webrtc.flutter.audio;
1+
package io.getstream.webrtc.flutter.audio;
22

3-
// import org.webrtc.audio.JavaAudioDeviceModule;
3+
import org.webrtc.audio.JavaAudioDeviceModule;
44

5-
// import java.util.ArrayList;
6-
// import java.util.List;
5+
import java.util.ArrayList;
6+
import java.util.List;
77

8-
// public class PlaybackSamplesReadyCallbackAdapter
9-
// implements JavaAudioDeviceModule.PlaybackSamplesReadyCallback {
10-
// public PlaybackSamplesReadyCallbackAdapter() {}
8+
public class PlaybackSamplesReadyCallbackAdapter
9+
implements JavaAudioDeviceModule.PlaybackSamplesReadyCallback {
10+
public PlaybackSamplesReadyCallbackAdapter() {}
1111

12-
// List<JavaAudioDeviceModule.PlaybackSamplesReadyCallback> callbacks = new ArrayList<>();
12+
List<JavaAudioDeviceModule.PlaybackSamplesReadyCallback> callbacks = new ArrayList<>();
1313

14-
// public void addCallback(JavaAudioDeviceModule.PlaybackSamplesReadyCallback callback) {
15-
// synchronized (callbacks) {
16-
// callbacks.add(callback);
17-
// }
18-
// }
14+
public void addCallback(JavaAudioDeviceModule.PlaybackSamplesReadyCallback callback) {
15+
synchronized (callbacks) {
16+
callbacks.add(callback);
17+
}
18+
}
1919

20-
// public void removeCallback(JavaAudioDeviceModule.PlaybackSamplesReadyCallback callback) {
21-
// synchronized (callbacks) {
22-
// callbacks.remove(callback);
23-
// }
24-
// }
20+
public void removeCallback(JavaAudioDeviceModule.PlaybackSamplesReadyCallback callback) {
21+
synchronized (callbacks) {
22+
callbacks.remove(callback);
23+
}
24+
}
2525

26-
// @Override
27-
// public void onWebRtcAudioTrackSamplesReady(JavaAudioDeviceModule.AudioSamples audioSamples) {
28-
// for (JavaAudioDeviceModule.PlaybackSamplesReadyCallback callback : callbacks) {
29-
// callback.onWebRtcAudioTrackSamplesReady(audioSamples);
30-
// }
31-
// }
32-
// }
26+
@Override
27+
public void onWebRtcAudioTrackSamplesReady(JavaAudioDeviceModule.AudioSamples audioSamples) {
28+
for (JavaAudioDeviceModule.PlaybackSamplesReadyCallback callback : callbacks) {
29+
callback.onWebRtcAudioTrackSamplesReady(audioSamples);
30+
}
31+
}
32+
}

0 commit comments

Comments
 (0)