* This example shows how to: *
- * The two sides use two factories. The sending factory is fed pushed audio, - * so it gets a dummy audio layer. The receiving factory gets the platform's - * audio layer, whose playout is what makes the received audio audible. + * One runtime serves both peers. Its {@link AudioMode#CUSTOM} audio mode sends + * the file's pushed audio and plays the received audio, which is what two + * factories did before the client API had audio modes. *
- * Audio and video stay in sync because both tracks are sent in the same - * media stream: the receiver lines them up with each other before handing - * them on, so the video sink only has to draw each frame as it arrives. + * Audio and video stay in sync because both tracks are sent in the same media + * stream: the receiver lines them up with each other before handing them on, + * so the view only has to draw each frame as it arrives. *
* Run it with an optional media file or stream URL to preselect: *
@@ -134,7 +119,7 @@ public class MediaFilePlayerExample {
private static final Logger LOG = Logger.getLogger(MediaFilePlayerExample.class.getName());
/** Both tracks go in this stream, which is what ties them together for lip sync. */
- private static final List STREAM_IDS = List.of("media-file");
+ private static final String STREAM_ID = "media-file";
/**
* The most the video may be sent with. Without a limit of its own, WebRTC
@@ -145,11 +130,10 @@ public class MediaFilePlayerExample {
*/
private static final int MAX_VIDEO_BITRATE = 10_000_000;
- private final AudioDeviceModule senderAudioModule;
- private final PeerConnectionFactory senderFactory;
+ private static final DateTimeFormatter RECORDING_NAME = DateTimeFormatter.ofPattern("'recording-'yyyyMMdd-HHmmss'.mkv'");
- private final AudioDeviceModule receiverAudioModule;
- private final PeerConnectionFactory receiverFactory;
+ /** Owns the peers and tracks of every session; its handlers run on the EDT. */
+ private final WebRtc rtc;
/** Setting up and tearing down a session blocks, so it stays off the EDT. */
private final ExecutorService worker = Executors.newSingleThreadExecutor(r -> {
@@ -163,13 +147,13 @@ public class MediaFilePlayerExample {
private final JButton browseButton = new JButton("Browse...");
private final JButton startButton = new JButton("Start");
private final JButton stopButton = new JButton("Stop");
+ private final JToggleButton recordButton = new JToggleButton("Record");
private final JCheckBox loopBox = new JCheckBox("Loop");
private final JLabel statusLabel = new JLabel("Idle");
private final JProgressBar timeBar = new JProgressBar(0, 1000);
- private final VideoPanel videoPanel = new VideoPanel();
+ private final VideoView videoView = new VideoView();
private final MetricsPanel metricsPanel = new MetricsPanel();
private final Timer statusTimer = new Timer(250, e -> updateStatus());
- private final Timer statsTimer = new Timer(1000, e -> requestStats());
/** Only touched from the worker thread and read on the EDT for status. */
private volatile Session session;
@@ -221,11 +205,13 @@ private static void usePlatformLookAndFeel() {
}
private MediaFilePlayerExample() {
- senderAudioModule = new AudioDeviceModule(AudioLayer.kDummyAudio);
- senderFactory = new PeerConnectionFactory(senderAudioModule);
+ // Pushed audio out, played audio in, and every handler on the EDT.
+ rtc = WebRtc.builder()
+ .audio(AudioMode.CUSTOM)
+ .eventExecutor(SwingUtilities::invokeLater)
+ .build();
- receiverAudioModule = new AudioDeviceModule();
- receiverFactory = new PeerConnectionFactory(receiverAudioModule);
+ videoView.setPreferredSize(new Dimension(960, 540));
}
private void show(String file) {
@@ -235,6 +221,7 @@ private void show(String file) {
browseButton.addActionListener(e -> chooseFile());
startButton.addActionListener(e -> start());
stopButton.addActionListener(e -> stop());
+ recordButton.addActionListener(e -> record(recordButton.isSelected()));
loopBox.addActionListener(e -> {
Session current = session;
if (current != null) {
@@ -247,6 +234,7 @@ private void show(String file) {
controls.add(browseButton);
controls.add(startButton);
controls.add(stopButton);
+ controls.add(recordButton);
controls.add(loopBox);
timeBar.setStringPainted(true);
@@ -259,7 +247,7 @@ private void show(String file) {
frame.setLayout(new BorderLayout());
frame.add(controls, BorderLayout.NORTH);
- frame.add(videoPanel, BorderLayout.CENTER);
+ frame.add(videoView, BorderLayout.CENTER);
frame.add(metricsPanel, BorderLayout.EAST);
frame.add(statusBar, BorderLayout.SOUTH);
frame.setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);
@@ -330,13 +318,14 @@ private void start() {
private void stop() {
startButton.setEnabled(false);
stopButton.setEnabled(false);
+ recordButton.setEnabled(false);
worker.execute(() -> {
closeSession();
SwingUtilities.invokeLater(() -> {
setRunning(false);
- videoPanel.clear();
+ videoView.clear();
statusLabel.setText("Stopped");
timeBar.setValue(0);
timeBar.setString("");
@@ -349,20 +338,41 @@ private void stop() {
});
}
+ /**
+ * Starts or stops recording what the receiver gets. Starting and stopping
+ * a recorder waits on the peers and on the file, so it runs on the worker.
+ */
+ private void record(boolean on) {
+ worker.execute(() -> {
+ Session current = session;
+ String message;
+
+ if (current == null) {
+ message = "Start playback to record it";
+ }
+ else if (on) {
+ message = current.startRecording();
+ }
+ else {
+ message = current.stopRecording();
+ }
+
+ SwingUtilities.invokeLater(() -> {
+ statusLabel.setText(message);
+ recordButton.setSelected(session != null && session.recorder != null);
+ });
+ });
+ }
+
private void exit() {
statusTimer.stop();
- statsTimer.stop();
frame.dispose();
// Queued behind anything still running, so a session being set up
// is closed rather than left behind.
worker.execute(() -> {
closeSession();
-
- receiverFactory.dispose();
- receiverAudioModule.dispose();
- senderFactory.dispose();
- senderAudioModule.dispose();
+ rtc.close();
System.exit(0);
});
@@ -380,20 +390,17 @@ private void closeSession() {
private void setRunning(boolean running) {
startButton.setEnabled(!running);
stopButton.setEnabled(running);
+ recordButton.setEnabled(running);
fileField.setEnabled(!running);
browseButton.setEnabled(!running);
if (!running) {
loopBox.setEnabled(true);
- }
-
- if (running) {
- statusTimer.start();
- statsTimer.start();
+ recordButton.setSelected(false);
+ statusTimer.stop();
}
else {
- statusTimer.stop();
- statsTimer.stop();
+ statusTimer.start();
}
}
@@ -412,27 +419,15 @@ private void updateStatus() {
? formatTime(positionUs) + " / " + formatTime(durationUs)
: formatTime(positionUs);
- statusLabel.setText(state.toString());
+ if (current.recorder == null) {
+ statusLabel.setText(state.toString());
+ }
timeBar.setValue(durationUs > 0 ? (int) Math.min(1000, positionUs * 1000 / durationUs) : 0);
timeBar.setString(time);
metricsPanel.set("play.state", state.toString());
metricsPanel.set("play.position", time);
- metricsPanel.set("play.connection", current.connectionState.toString());
- }
-
- /**
- * Asks the current session for its statistics. This goes through the
- * worker, which is where sessions are closed, so a request can never
- * reach a peer connection that is being closed at the same time.
- */
- private void requestStats() {
- worker.execute(() -> {
- Session current = session;
- if (current != null) {
- current.requestStats();
- }
- });
+ metricsPanel.set("play.connection", current.receiver.state().toString());
}
private static String formatTime(long us) {
@@ -509,7 +504,7 @@ private static Double decimal(Map attributes, String name) {
/**
* One run of the file, from Start to Stop: the source, the sending and
- * receiving peer connections, and what connects them.
+ * receiving peers, the tracks over the file's sources, and a recording.
*/
private class Session {
@@ -519,15 +514,16 @@ private class Session {
final Peer sender;
final Peer receiver;
- private final VideoTrack videoTrack;
- private final AudioTrack audioTrack;
- private RTCRtpSender videoSender;
- private final List rtpSenders = new ArrayList<>();
+ private final LocalVideo videoTrack;
+ private final LocalAudio audioTrack;
- volatile RTCPeerConnectionState connectionState = RTCPeerConnectionState.NEW;
+ /** What the receiver gets, kept for recording. Set on the EDT. */
+ private volatile RemoteTrack remoteVideo;
+ private volatile RemoteTrack remoteAudio;
- /** The received video track, kept to detach the sink from on close. */
- private volatile VideoTrack remoteVideoTrack;
+ /** The recording running, if any. Only touched on the worker. */
+ volatile MediaRecorder recorder;
+ private Path recording;
/** Turn the byte counters of successive stats reports into bitrates. */
private final RateMeter videoRate = new RateMeter();
@@ -538,27 +534,40 @@ private class Session {
source = new MediaFileSource(file);
info = source.getInfo();
- sender = new Peer(senderFactory, "sender");
- receiver = new Peer(receiverFactory, "receiver");
+ // The peers find each other in process; across a network the
+ // messages would go over a WebSocket instead.
+ SignalingPair link = Signaling.loopback();
+ sender = rtc.createPeer(PeerOptions.builder().name("sender").signaling(link.first()).build());
+ receiver = rtc.createPeer(PeerOptions.builder().name("receiver").signaling(link.second())
+ .polite(true).build());
- sender.remote = receiver;
- receiver.remote = sender;
+ receiver.onStateChange(state -> LOG.info("Receiver connection: " + state));
+ receiver.onTrack(this::onRemoteTrack);
+ receiver.onStats(Duration.ofSeconds(1), this::showStats);
// A source with no video has no video source, and likewise for
// audio, so each track is only made if there is something to feed
- // it.
+ // it. The tracks wrap the file's sources, which stay the file's.
if (source.getVideoSource() != null) {
- videoTrack = senderFactory.createVideoTrack("video", source.getVideoSource());
- videoSender = sender.peerConnection.addTrack(videoTrack, STREAM_IDS);
- rtpSenders.add(videoSender);
+ videoTrack = rtc.media().videoTrack("video", source.getVideoSource());
+ Sender videoSender = sender.addTrack(videoTrack, STREAM_ID);
+
+ // Encodings exist once negotiation set the sender up.
+ sender.whenConnected()
+ .thenCompose(connected -> videoSender.configure(
+ Encoding.builder().maxBitrate(MAX_VIDEO_BITRATE).build()))
+ .exceptionally(error -> {
+ LOG.log(Level.WARNING, "Could not raise the video bitrate", error);
+ return null;
+ });
}
else {
videoTrack = null;
}
if (source.getAudioSource() != null) {
- audioTrack = senderFactory.createAudioTrack("audio", source.getAudioSource());
- rtpSenders.add(sender.peerConnection.addTrack(audioTrack, STREAM_IDS));
+ audioTrack = rtc.media().audioTrack("audio", source.getAudioSource());
+ sender.addTrack(audioTrack, STREAM_ID);
}
else {
audioTrack = null;
@@ -584,44 +593,31 @@ public void onError(String message) {
}
});
- try {
- // The offer and answer go straight across, where an application
- // talking to a real remote peer would send them over signaling.
- RTCSessionDescription offer = sender.createOffer();
- receiver.setRemoteDescription(offer);
-
- RTCSessionDescription answer = receiver.createAnswer();
- sender.setRemoteDescription(answer);
-
- if (videoSender != null) {
- raiseMaxBitrate(videoSender, MAX_VIDEO_BITRATE);
- }
- }
- catch (Exception e) {
- close();
- throw e;
- }
-
// Frames are sent in real time from the moment playback starts,
// and whatever goes out before the connection is up is dropped.
// Starting right away keeps the example short; an application
- // that must not lose the first second would wait for CONNECTED.
+ // that must not lose the first second would wait for
+ // receiver.whenConnected().
source.play();
}
- /**
- * Lets a sender use up to the given bitrate. Parameters are read,
- * changed and written back as a whole, and only have encodings to
- * change once negotiation has set the sender up.
- */
- private void raiseMaxBitrate(RTCRtpSender rtpSender, int bitrate) {
- RTCRtpSendParameters parameters = rtpSender.getParameters();
-
- for (RTCRtpEncodingParameters encoding : parameters.encodings) {
- encoding.maxBitrate = bitrate;
+ /** On the EDT: shows the video, and keeps both tracks for recording. */
+ private void onRemoteTrack(RemoteTrack track) {
+ if (track.isVideo()) {
+ remoteVideo = track;
+ track.asVideo().onFrame(videoView);
+ }
+ else {
+ // Nothing to do for playback: the runtime plays received audio.
+ remoteAudio = track;
}
+ }
- rtpSender.setParameters(parameters);
+ /** On the EDT, once a second. */
+ private void showStats(PeerStats stats) {
+ if (session == this) {
+ metricsPanel.setAll(readStats(stats.report()));
+ }
}
/**
@@ -637,20 +633,66 @@ private void stopIfCurrent() {
});
}
- /**
- * Collects the receiving side's statistics and shows them once they
- * arrive, unless the session has ended in the meantime.
- */
- void requestStats() {
- receiver.peerConnection.getStats(report -> {
- Map values = readStats(report);
+ /** On the worker. */
+ String startRecording() {
+ if (recorder != null) {
+ return "Recording to " + recording;
+ }
+ if (remoteVideo == null && remoteAudio == null) {
+ return "Nothing received yet to record";
+ }
- SwingUtilities.invokeLater(() -> {
- if (session == this) {
- metricsPanel.setAll(values);
+ Path file = Paths.get(LocalDateTime.now().format(RECORDING_NAME)).toAbsolutePath();
+
+ try {
+ MediaRecorder started = new MediaRecorder(file);
+ started.setListener(new MediaRecorderListener() {
+
+ @Override
+ public void onWarning(String message) {
+ LOG.warning("Recording: " + message);
+ }
+
+ @Override
+ public void onError(String message) {
+ LOG.warning("Recording failed: " + message);
}
});
- });
+
+ // The receiver's tracks as they arrived, before decoding.
+ if (remoteVideo != null) {
+ started.addTrack(remoteVideo);
+ }
+ if (remoteAudio != null) {
+ started.addTrack(remoteAudio);
+ }
+
+ started.start();
+
+ recorder = started;
+ recording = file;
+
+ return "Recording to " + file;
+ }
+ catch (Exception e) {
+ LOG.log(Level.WARNING, "Could not start recording", e);
+ return "Could not record: " + e.getMessage();
+ }
+ }
+
+ /** On the worker. */
+ String stopRecording() {
+ MediaRecorder running = recorder;
+ recorder = null;
+
+ if (running == null) {
+ return "Not recording";
+ }
+
+ boolean recorded = running.stop();
+ running.close();
+
+ return recorded ? "Saved " + recording : "Nothing was recorded";
}
/**
@@ -705,177 +747,30 @@ else if ("audio".equals(attributes.get("kind"))) {
return values;
}
- void onRemoteTrack(MediaStreamTrack track) {
- if (track instanceof VideoTrack) {
- remoteVideoTrack = (VideoTrack) track;
- remoteVideoTrack.addSink(videoPanel);
- }
- // A received audio track needs nothing: the receiving factory's
- // audio device module mixes it into playout on its own.
- }
-
+ /** On the worker. */
void close() {
- // Stop drawing before anything goes away underneath the sink.
- VideoTrack remoteVideo = remoteVideoTrack;
- if (remoteVideo != null) {
- remoteVideo.removeSink(videoPanel);
- }
-
- // Senders are not owned by the peer connection. Releasing them
- // before it closes lets go of the tracks they carry.
- for (RTCRtpSender rtpSender : rtpSenders) {
- rtpSender.dispose();
- }
-
- sender.close();
- receiver.close();
-
- // The tracks go before the source, which disposes of the media
- // sources they were made from.
- if (videoTrack != null) {
- videoTrack.dispose();
- }
- if (audioTrack != null) {
- audioTrack.dispose();
- }
-
- source.close();
- }
-
-
- /**
- * One end of the in-process connection. Candidates found here are
- * handed to the other end, held back until it has a remote
- * description to match them against.
- */
- private class Peer implements PeerConnectionObserver {
-
- final RTCPeerConnection peerConnection;
-
- private final String name;
-
- private final List pendingCandidates = new ArrayList<>();
-
- private boolean hasRemoteDescription;
-
- Peer remote;
-
-
- Peer(PeerConnectionFactory factory, String name) {
- this.name = name;
- this.peerConnection = factory.createPeerConnection(new RTCConfiguration(), this);
+ if (recorder != null) {
+ LOG.info(stopRecording());
}
- RTCSessionDescription createOffer() throws Exception {
- CompletableFuture offer = new CompletableFuture<>();
- peerConnection.createOffer(new RTCOfferOptions(), createObserver(offer));
-
- return setLocalDescription(offer.get());
- }
-
- RTCSessionDescription createAnswer() throws Exception {
- CompletableFuture answer = new CompletableFuture<>();
- peerConnection.createAnswer(new RTCAnswerOptions(), createObserver(answer));
-
- return setLocalDescription(answer.get());
- }
-
- RTCSessionDescription setLocalDescription(RTCSessionDescription description)
- throws Exception {
- CompletableFuture done = new CompletableFuture<>();
- peerConnection.setLocalDescription(description, setObserver(done));
- done.get();
-
- return description;
- }
-
- void setRemoteDescription(RTCSessionDescription description) throws Exception {
- CompletableFuture done = new CompletableFuture<>();
- peerConnection.setRemoteDescription(description, setObserver(done));
- done.get();
-
- List candidates;
- synchronized (this) {
- hasRemoteDescription = true;
- candidates = new ArrayList<>(pendingCandidates);
- pendingCandidates.clear();
- }
-
- candidates.forEach(peerConnection::addIceCandidate);
- }
+ try {
+ // The peers go first, then the tracks, which must be released
+ // before the file closes the sources they were made over.
+ sender.closeAsync().get(5, TimeUnit.SECONDS);
+ receiver.closeAsync().get(5, TimeUnit.SECONDS);
- void addRemoteCandidate(RTCIceCandidate candidate) {
- synchronized (this) {
- if (!hasRemoteDescription) {
- pendingCandidates.add(candidate);
- return;
- }
+ if (videoTrack != null) {
+ videoTrack.closeAsync().get(5, TimeUnit.SECONDS);
}
-
- peerConnection.addIceCandidate(candidate);
- }
-
- void close() {
- peerConnection.close();
- }
-
- @Override
- public void onIceCandidate(RTCIceCandidate candidate) {
- remote.addRemoteCandidate(candidate);
- }
-
- @Override
- public void onConnectionChange(RTCPeerConnectionState state) {
- LOG.info(name + " connection state: " + state);
-
- if (this == receiver) {
- connectionState = state;
+ if (audioTrack != null) {
+ audioTrack.closeAsync().get(5, TimeUnit.SECONDS);
}
}
-
- @Override
- public void onTrack(RTCRtpTransceiver transceiver) {
- RTCRtpReceiver rtpReceiver = transceiver.getReceiver();
-
- onRemoteTrack(rtpReceiver.getTrack());
-
- // The receiver and transceiver are query results the
- // application owns. The track itself is unaffected and keeps
- // delivering frames to its sink.
- rtpReceiver.dispose();
- transceiver.dispose();
- }
-
- private CreateSessionDescriptionObserver createObserver(
- CompletableFuture future) {
- return new CreateSessionDescriptionObserver() {
-
- @Override
- public void onSuccess(RTCSessionDescription description) {
- future.complete(description);
- }
-
- @Override
- public void onFailure(String error) {
- future.completeExceptionally(new Exception(name + ": " + error));
- }
- };
+ catch (Exception e) {
+ LOG.log(Level.WARNING, "Closing the session took too long", e);
}
- private SetSessionDescriptionObserver setObserver(CompletableFuture future) {
- return new SetSessionDescriptionObserver() {
-
- @Override
- public void onSuccess() {
- future.complete(null);
- }
-
- @Override
- public void onFailure(String error) {
- future.completeExceptionally(new Exception(name + ": " + error));
- }
- };
- }
+ source.close();
}
}
@@ -1048,91 +943,4 @@ private void addRow(String key, String name) {
row++;
}
}
-
-
-
- /**
- * Draws the most recent received video frame, scaled to fit while keeping
- * its aspect ratio.
- *
- * Frames arrive on a WebRTC thread already timed to match the audio, so
- * they are converted there and only the drawing is left to the EDT.
- */
- private static class VideoPanel extends JPanel implements VideoTrackSink {
-
- private BufferedImage image;
-
- private ByteBuffer pixelBuffer;
-
-
- VideoPanel() {
- setBackground(Color.BLACK);
- setPreferredSize(new Dimension(960, 540));
- }
-
- @Override
- public void onVideoFrame(VideoFrame frame) {
- VideoFrameBuffer buffer = frame.buffer;
- int width = buffer.getWidth();
- int height = buffer.getHeight();
-
- try {
- synchronized (this) {
- if (image == null || image.getWidth() != width || image.getHeight() != height) {
- image = new BufferedImage(width, height, BufferedImage.TYPE_INT_RGB);
- pixelBuffer = ByteBuffer.allocateDirect(width * height * 4)
- .order(ByteOrder.LITTLE_ENDIAN);
- }
-
- // libyuv's ARGB is B, G, R, A in memory, which read as
- // little-endian ints is exactly what TYPE_INT_RGB holds.
- pixelBuffer.clear();
- VideoBufferConverter.convertFromI420(buffer, pixelBuffer, FourCC.ARGB);
- pixelBuffer.rewind();
-
- int[] pixels = ((DataBufferInt) image.getRaster().getDataBuffer()).getData();
- pixelBuffer.asIntBuffer().get(pixels);
- }
- }
- catch (Exception e) {
- LOG.log(Level.WARNING, "Could not convert a video frame", e);
- }
- finally {
- frame.release();
- }
-
- repaint();
- }
-
- void clear() {
- synchronized (this) {
- image = null;
- pixelBuffer = null;
- }
- repaint();
- }
-
- @Override
- protected void paintComponent(Graphics g) {
- super.paintComponent(g);
-
- synchronized (this) {
- if (image == null) {
- return;
- }
-
- double scale = Math.min((double) getWidth() / image.getWidth(),
- (double) getHeight() / image.getHeight());
- int w = (int) (image.getWidth() * scale);
- int h = (int) (image.getHeight() * scale);
- int x = (getWidth() - w) / 2;
- int y = (getHeight() - h) / 2;
-
- Graphics2D g2 = (Graphics2D) g;
- g2.setRenderingHint(RenderingHints.KEY_INTERPOLATION,
- RenderingHints.VALUE_INTERPOLATION_BILINEAR);
- g2.drawImage(image, x, y, w, h, null);
- }
- }
- }
}
diff --git a/webrtc/src/main/java/dev/onvoid/webrtc/client/LocalTrack.java b/webrtc/src/main/java/dev/onvoid/webrtc/client/LocalTrack.java
index a5ccd193..9ea63ded 100644
--- a/webrtc/src/main/java/dev/onvoid/webrtc/client/LocalTrack.java
+++ b/webrtc/src/main/java/dev/onvoid/webrtc/client/LocalTrack.java
@@ -16,6 +16,8 @@
package dev.onvoid.webrtc.client;
+import java.util.concurrent.CompletableFuture;
+
/**
* A track this side sends, made by {@link WebRtc#media()}. One track may be sent
* on any number of peers.
@@ -60,6 +62,16 @@ public interface LocalTrack extends AutoCloseable {
*/
boolean isEnded();
+ /**
+ * Stops sending the track on every peer, without renegotiating, and stops
+ * its capture.
+ *
+ * @return a future that completes once the native track is released, after
+ * which a source the track was made over, with {@link
+ * LocalMedia#videoTrack} or {@link LocalMedia#audioTrack}, may be closed.
+ */
+ CompletableFuture closeAsync();
+
/**
* Stops sending the track on every peer, without renegotiating, and stops
* its capture. Never blocks, may be called more than once.
diff --git a/webrtc/src/main/java/dev/onvoid/webrtc/client/LocalTrackImpl.java b/webrtc/src/main/java/dev/onvoid/webrtc/client/LocalTrackImpl.java
index 0ba77a13..90db93d3 100644
--- a/webrtc/src/main/java/dev/onvoid/webrtc/client/LocalTrackImpl.java
+++ b/webrtc/src/main/java/dev/onvoid/webrtc/client/LocalTrackImpl.java
@@ -124,6 +124,11 @@ public synchronized boolean isEnded() {
return ended;
}
+ @Override
+ public CompletableFuture closeAsync() {
+ return closeInternal();
+ }
+
@Override
public void close() {
closeInternal();
diff --git a/webrtc/src/test/java/dev/onvoid/webrtc/client/MediaTests.java b/webrtc/src/test/java/dev/onvoid/webrtc/client/MediaTests.java
index 7a1c456e..f786b277 100644
--- a/webrtc/src/test/java/dev/onvoid/webrtc/client/MediaTests.java
+++ b/webrtc/src/test/java/dev/onvoid/webrtc/client/MediaTests.java
@@ -329,6 +329,10 @@ void tracksOverOwnSources() throws Exception {
VideoFrame frame = new VideoFrame(NativeI420Buffer.allocate(160, 120), System.nanoTime());
videoSource.pushFrame(frame);
frame.release();
+
+ // Once released, the source may go before the runtime does.
+ await(audio.closeAsync());
+ assertTrue(audio.isEnded());
}
finally {
feeder.shutdownNow();