Skip to main content

AsyncMediaSource

Struct AsyncMediaSource 

Source
pub struct AsyncMediaSource<R> { /* private fields */ }

Implementations§

Source§

impl<R: AsyncRead + Unpin> AsyncMediaSource<R>

Source

pub fn kind(&self) -> MediaKind

Source§

impl AsyncMediaSource<Empty>

Source

pub fn from_memory(bytes: impl Into<Bytes>) -> Result<Self>

Build an AsyncMediaSource from an in-memory byte payload.

Async counterpart of crate::MediaSource::from_memory. Returns AsyncMediaSource<tokio::io::Empty>, which satisfies the <R: AsyncRead + Unpin + Send> bound on MediaParser::parse_exif_async, parse_track_async, and parse_image_metadata_async so a single async entry point per “what to parse” handles both streaming and in-memory inputs.

Accepts any type convertible into bytes::BytesBytes, Vec<u8>, &'static [u8], String, Box<[u8]>, plus HTTP-stack body types implementing Into<Bytes>. Zero-copy: parsed ExifIter / sub-IFDs share the original Bytes via reference counting, no copy.

§Example
use nom_exif::{AsyncMediaSource, MediaKind, MediaParser};

let bytes = tokio::fs::read("./testdata/exif.jpg").await?;
let ms = AsyncMediaSource::from_memory(bytes)?;
assert_eq!(ms.kind(), MediaKind::Image);

let mut parser = MediaParser::new();
let _iter = parser.parse_exif_async(ms).await?;
Source§

impl<R: AsyncRead + AsyncSeek + Unpin + Send> AsyncMediaSource<R>

Source

pub async fn seekable(reader: R) -> Result<Self>

Source§

impl<R: AsyncRead + Unpin + Send> AsyncMediaSource<R>

Source

pub async fn unseekable(reader: R) -> Result<Self>

Source§

impl AsyncMediaSource<File>

Source

pub async fn open<P: AsRef<Path>>(path: P) -> Result<Self>

Open a file at path (via tokio::fs::File) and parse its header. For an already-open async File use Self::seekable.

Trait Implementations§

Source§

impl<R> Debug for AsyncMediaSource<R>

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<R> !Freeze for AsyncMediaSource<R>

§

impl<R> RefUnwindSafe for AsyncMediaSource<R>
where R: RefUnwindSafe,

§

impl<R> Send for AsyncMediaSource<R>
where R: Send,

§

impl<R> Sync for AsyncMediaSource<R>
where R: Sync,

§

impl<R> Unpin for AsyncMediaSource<R>
where R: Unpin,

§

impl<R> UnsafeUnpin for AsyncMediaSource<R>
where R: UnsafeUnpin,

§

impl<R> UnwindSafe for AsyncMediaSource<R>
where R: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more