Alternative StreamMap fork of tokio-stream

Last update: Aug 18, 2022

Related tags

Overview

streammap-ext

This is a fork of StreamMap from tokio-stream crate. The only difference between the implementations is that this version of StreamMap next returns Option<K,Option<V>> instead of Option<K,V>. This is to allow the developer to be aware when a stream is being dropped from the StreamMap, without the need to implement a Drop trait which can be troublesome in some cases (e.g. the drop flow requires async code).

After releasing this crate, I'll open a discussion to consider how to contribute it back to the original crate (as a different name, maybe a PhantomData that marks behavior, or maybe change the current behavior to this).

LICENSE

MIT - Same as source, all copy right goes to Tokio Contributors as this is a fork of tokio-stream crate.

Mix async code with CPU-heavy thread pools using Tokio + Rayon

tokio-rayon Mix async code with CPU-heavy thread pools using Tokio + Rayon Resources Documentation crates.io TL;DR Sometimes, you're doing async stuff

74 Jan 2, 2023

Provides utility functions to perform a graceful shutdown on an tokio-rs based service

tokio-graceful-shutdown IMPORTANT: This crate is in an early stage and not ready for production. This crate provides utility functions to perform a gr

61 Jan 8, 2023

An asynchronous IO utilities crate powered by tokio.

2 Aug 18, 2022

dark-std an Implementation of asynchronous containers build on tokio

dark-std dark-std is an Implementation of asynchronous containers build on tokio. It uses a read-write separation design borrowed from Golang SyncHash

4 Dec 13, 2022

Pure Rust library for Apache ZooKeeper built on tokio

zookeeper-async Async Zookeeper client written 100% in Rust, based on tokio. This library is intended to be equivalent with the official (low-level) Z

16 Dec 16, 2022

Thin wrapper around [`tokio::process`] to make it streamable

This library provide ProcessExt to create your own custom process

4 Jun 25, 2022

Rc version `tokio-rs/bytes`

RcBytes The aim for this crate is to implement a Rc version bytes, which means that the structs in this crate does not implement the Sync and Send. Th

2 Aug 1, 2022

Graceful shutdown util for Rust projects using the Tokio Async runtime.

Shutdown management for graceful shutdown of tokio applications. Guard creating and usage is lock-free and the crate only locks when: the shutdown sig

54 Sep 29, 2023

Async Rust cron scheduler running on Tokio.

Grizzly Cron Scheduler A simple and easy to use scheduler, built on top of Tokio, that allows you to schedule async tasks using cron expressions (with

4 Feb 27, 2024

Releases(0.1.0)

0.1.0(Jul 20, 2022)
0.1.0

Initial Release

Source code(tar.gz)
Source code(zip)

Owner

MetalBear

Rethinking Cloud Development

GitHub

Noir Pay - Fork of the Light Protocol Program for local testing / optimisation.

Noir Pay v0 Built on Light Protocol Noir Pay will be directly built ontop of the Light Protocol SDK and provide users with a beautifully simple privat

1 Feb 12, 2022

Rust Shop is a fake cloud-based software company that you can fork.

RustShop RustShop is an attempt at building a template and utilities to help quickly set up and manage a production grade cloud-based system. The core

56 Dec 17, 2022

A fork of 'discord-token-botter' for rust lang.

Shahzain Botter V3(Rust) - If you were sold this tool, you have been scammed, this tool is free & open source Please DO NOT pay money for this tool A

5 Nov 7, 2022

Docgen - a fork of Doctave intending to continue the development.

Docgen Docgen is a fork of Doctave intending to continue the development. All credit goes to the original Docgen authors. Docgen is an opinionated doc

3 Oct 22, 2022

fork of erupt-bootstrap for ash

ash-bootstrap Vulkan Bootstrapping library for Rust, inspired by vk-bootstrap. ✅ Instance creation ✅ Physical Device selection ✅ Device creation ✅ Get

4 Dec 22, 2022

A VtubeStudio plugin that allows iFacialMocap to stream data to the app, enabling full apple ARkit facial tracking to be used for 2D Vtuber models.

facelink_rs A VtubeStudio plugin that allows iFacialMocap to stream data to the app, enabling full apple ARkit facial tracking to be used for 2D Vtube

2 May 6, 2022