xqq

use async_condvar_fair::{Condvar, BatonExt};
use bytes::{BufMut, Bytes, BytesMut};
use std::collections::VecDeque;
use std::ops::DerefMut;
use std::sync::Arc;
use tokio::sync::Mutex;

/// Create an unbounded channel with the specified minimum buffering size, in bytes.
pub fn buffered_bytes_channel(threshold_size: usize) -> (Sender, Receiver) {
    let shared = Arc::new((Mutex::new(Default::default()), Condvar::new()));

xqq

/*****************************************************************************
 * ARIB STD-B24 caption decoder/renderer using libaribcaption.
 *****************************************************************************
 * Copyright (C) 2022 magicxqq
 *
 * Authors:  magicxqq <[email protected]>
 *
 * This program is free software; you can redistribute it and/or modify it
 * under the terms of the GNU Lesser General Public License as published by
 * the Free Software Foundation; either version 2.1 of the License, or

xqq

#include <iostream>
#include <string>
#include <vector>
#include <cstdlib>
#include <cstdint>
#include <algorithm>
#include <numeric>
#include <unordered_map>

using std::string;

xqq

Keybase proof

I hereby claim:

• I am xqq on github.
• I am xqq (https://keybase.io/xqq) on keybase.
• I have a public key ASBl_2r_yshO8qW3WzH83pAiK1H3O-wVI51Mfje4fMDQNgo

To claim this, I am signing this object: