libktx-rs 0.3.3

Reading, writing and transcoding of Khronos Textures (KTX1 and KTX2).
Documentation 
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
45
46
47
48
49
50
51
52

// Copyright (C) 2021 Paolo Jovon <paolo.jovon@gmail.com>
// SPDX-License-Identifier: Apache-2.0
#![cfg(feature = "write")]

//! [`crate::texture::TextureSink`] implementations for writing [`Texture`]s out to.

use crate::{
    enums::ktx_result,
    stream::{RWSeekable, RustKtxStream},
    texture::{Texture, TextureSink},
    KtxError,
};
use std::sync::{Arc, Mutex};

/// A [`TextureSink`] that writes to a [`RustKtxStream`].
#[derive(Debug)]
pub struct StreamSink<'a, T: RWSeekable + ?Sized + 'a> {
    stream: Arc<Mutex<RustKtxStream<'a, T>>>,
}

impl<'a, T: RWSeekable + ?Sized + 'a> StreamSink<'a, T> {
    /// Creates a new stream sink that will write to the given `inner` stream.
    pub fn new(inner: Arc<Mutex<RustKtxStream<'a, T>>>) -> Self {
        StreamSink { stream: inner }
    }

    /// Destroys this stream sink, giving back the underlying `inner` stream.
    pub fn into_inner(self) -> Arc<Mutex<RustKtxStream<'a, T>>> {
        self.stream
    }
}

impl<'a, T: RWSeekable + ?Sized + 'a> TextureSink for StreamSink<'a, T> {
    fn write_texture(&mut self, texture: &Texture) -> Result<(), KtxError> {
        // SAFETY: Safe if `texture.handle` is sound.
        let vtbl = unsafe { (*texture.handle).vtbl };
        let write_pfn = match unsafe { (*vtbl).WriteToStream } {
            Some(pfn) => pfn,
            None => return Err(KtxError::InvalidValue),
        };
        let err = unsafe {
            write_pfn(
                texture.handle,
                self.stream
                    .lock()
                    .expect("Poisoned self.stream lock")
                    .ktx_stream(),
            )
        };
        ktx_result(err, ())
    }
}