Skip to content

Commit

Permalink
refactor(pipeline): use more general fn name
Browse files Browse the repository at this point in the history
  • Loading branch information
SeaDve committed Mar 6, 2024
1 parent 68916f1 commit 41c003a
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 9 deletions.
2 changes: 1 addition & 1 deletion src/area_selector/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -220,7 +220,7 @@ impl AreaSelector {
let pipeline = gst::Pipeline::new();
imp.pipeline.set(pipeline.clone()).unwrap();

let videosrc_bin = pipeline::make_pipewiresrc_bin(fd, streams, PREVIEW_FRAMERATE)?;
let videosrc_bin = pipeline::make_videosrc_bin(fd, streams, PREVIEW_FRAMERATE)?;
let gtksink = gst::ElementFactory::make("gtk4paintablesink").build()?;

let paintable = gtksink.property::<gdk::Paintable>("paintable");
Expand Down
12 changes: 4 additions & 8 deletions src/pipeline.rs
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ impl PipelineBuilder {

let pipeline = gst::Pipeline::new();

let videosrc_bin = make_pipewiresrc_bin(self.fd, &self.streams, self.framerate)
let videosrc_bin = make_videosrc_bin(self.fd, &self.streams, self.framerate)
.context("Failed to create videosrc bin")?;
let videoenc_queue = gst::ElementFactory::make("queue")
.name("kooha-videoenc-queue")
Expand Down Expand Up @@ -130,7 +130,7 @@ impl PipelineBuilder {
self.record_microphone
.then(|| make_pulsesrc(DeviceClass::Source, "kooha-microphone-src")),
];
let audiosrc_bin = make_pulsesrc_bin(
let audiosrc_bin = make_audiosrc_bin(
&pulsesrcs
.into_iter()
.flatten()
Expand Down Expand Up @@ -259,11 +259,7 @@ fn make_videocrop(data: &SelectAreaData) -> Result<gst::Element> {
/// pipewiresrc2 -> videoflip -> | -> compositor -> videorate
/// |
/// pipewiresrcn -> videoflip -> |
pub fn make_pipewiresrc_bin(
fd: RawFd,
streams: &[Stream],
framerate: Framerate,
) -> Result<gst::Bin> {
pub fn make_videosrc_bin(fd: RawFd, streams: &[Stream], framerate: Framerate) -> Result<gst::Bin> {
let bin = gst::Bin::builder().name("kooha-pipewiresrc-bin").build();

let videorate = gst::ElementFactory::make("videorate")
Expand Down Expand Up @@ -368,7 +364,7 @@ fn make_pulsesrc(class: DeviceClass, element_name: &str) -> Result<gst::Element>
/// pulsesrc2 -> audiorate -> | -> audiomixer
/// |
/// pulsesrcn -> audiorate -> |
fn make_pulsesrc_bin<'a>(
fn make_audiosrc_bin<'a>(
pulsesrcs: impl IntoIterator<Item = &'a gst::Element>,
) -> Result<gst::Bin> {
let bin = gst::Bin::builder().name("kooha-pulsesrc-bin").build();
Expand Down

0 comments on commit 41c003a

Please sign in to comment.