#include "livekit/rtp_receiver.h"
#include <memory>
#include "absl/types/optional.h"
namespace livekit {
RtpReceiver::RtpReceiver(
std::shared_ptr<RtcRuntime> rtc_runtime,
rtc::scoped_refptr<webrtc::RtpReceiverInterface> receiver)
: rtc_runtime_(rtc_runtime), receiver_(std::move(receiver)) {}
std::shared_ptr<MediaStreamTrack> RtpReceiver::track() const {
return rtc_runtime_->get_or_create_media_stream_track(receiver_->track());
}
rust::Vec<rust::String> RtpReceiver::stream_ids() const {
rust::Vec<rust::String> rust;
for (auto id : receiver_->stream_ids())
rust.push_back(id);
return rust;
}
rust::Vec<MediaStreamPtr> RtpReceiver::streams() const {
rust::Vec<MediaStreamPtr> rust;
for (auto stream : receiver_->streams())
rust.push_back(
MediaStreamPtr{std::make_shared<MediaStream>(rtc_runtime_, stream)});
return rust;
}
MediaType RtpReceiver::media_type() const {
return static_cast<MediaType>(receiver_->media_type());
}
rust::String RtpReceiver::id() const {
return receiver_->id();
}
RtpParameters RtpReceiver::get_parameters() const {
return to_rust_rtp_parameters(receiver_->GetParameters());
}
void RtpReceiver::set_jitter_buffer_minimum_delay(bool is_some,
double delay_seconds) const {
receiver_->SetJitterBufferMinimumDelay(
is_some ? absl::make_optional(delay_seconds) : absl::nullopt);
}
}