siritori

import { strict as assert } from 'assert';
import { Operator, OperatorFunction, Subscriber } from "rxjs";

export type FilterMap<T, U> = (e: T, index: number) => U | null;

class FilterMapSubscriber<T, U> extends Subscriber<T> {
    private count = 0;
    private readonly thisArg: any;
    constructor(
        destination: Subscriber<U>,

siritori

use bytes::Buf;

pub trait BinaryRead: Sized {
    fn read<T: bytes::Buf>(reader: &mut BinaryReader<T>) -> Option<Self>;
}

pub struct BinaryReader<T: bytes::Buf> {
    pub buf: T,
}