device 0.0.4

A generative engine
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use super::*;

pub(crate) struct RecorderThread {
  handle: JoinHandle<Result<Recorder>>,
  tx: mpsc::Sender<(u64, Image, Sound)>,
}

impl RecorderThread {
  pub(crate) fn finish(self, options: &Options, config: &Config) -> Result {
    drop(self.tx);

    match self.handle.join() {
      Ok(Ok(recorder)) => recorder.finish(options, config),
      Ok(Err(err)) => Err(err),
      Err(panic_value) => Err(error::RecordingJoin { panic_value }.build()),
    }
  }

  pub(crate) fn is_finished(&self) -> bool {
    self.handle.is_finished()
  }

  pub(crate) fn new(mut recorder: Recorder) -> Result<Self> {
    let (tx, rx) = mpsc::channel();

    let handle = thread_spawn("recorder", move || {
      loop {
        let Ok((frame, image, sound)) = rx.recv() else {
          break;
        };

        recorder.frame(frame, image, sound)?;
      }

      Ok(recorder)
    })?;

    Ok(Self { handle, tx })
  }

  pub(crate) fn tx(&self) -> &mpsc::Sender<(u64, Image, Sound)> {
    &self.tx
  }
}