flowly-codec-openh264 0.1.3

Flowly OpenH264 bindings
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use flowly::{Context, Service, ServiceExt};
use flowly_codec_openh264::Openh264Decoder;
use flowly_flv::FlvDemuxer;

use std::{path::PathBuf, pin::pin};

use futures::TryStreamExt;

#[tokio::main]
async fn main() {
    let mut flow = flowly::flow()
        .flow(flowly::io::file::FileReader::new(8192))
        .flow(FlvDemuxer::default())
        .flow(Openh264Decoder::default());

    let cx = Context::new();

    let mut stream = pin!(flow.handle(PathBuf::from("/home/andrey/demo/h264/test.flv"), &cx));

    while let Some(frame) = stream.try_next().await.unwrap() {
        println!("got frame {}", frame.timestamp);
    }
}