diff options
| author | Felix Kaaman <tmtu@tmtu.ee> | 2020-01-27 22:32:52 +0100 |
|---|---|---|
| committer | Jokler <jokler@protonmail.com> | 2020-01-27 22:32:52 +0100 |
| commit | b85ec0cedaf28b5252162b365881520fdb80c452 (patch) | |
| tree | c97b91f3c2999b84c9931d5b2acfd8d645f5a3f5 /src/audio_player.rs | |
| parent | a6e9551c19e082c0e12f1518300b6459e4791b95 (diff) | |
| download | pokebot-b85ec0cedaf28b5252162b365881520fdb80c452.tar.gz pokebot-b85ec0cedaf28b5252162b365881520fdb80c452.zip | |
Change method of sending EOS to GStreamer pipeline (#24)
Uses message bus instead of events to elements
Diffstat (limited to 'src/audio_player.rs')
| -rw-r--r-- | src/audio_player.rs | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/audio_player.rs b/src/audio_player.rs index 68fcc7b..97a61cd 100644 --- a/src/audio_player.rs +++ b/src/audio_player.rs @@ -231,13 +231,12 @@ impl AudioPlayer { Ok(()) } - pub fn stop_current(&self) { + pub fn stop_current(&self) -> Result<(), AudioPlayerError> { info!("Stopping pipeline, sending EOS"); - let handled = self.http_src.send_event(gst::Event::new_eos().build()); - if !handled { - warn!("EOS event was not handled"); - } + self.bus.post(&gst::Message::new_eos().build())?; + + Ok(()) } fn send_state(&self, state: State) { |