GitHub topics: streams

robinjoseph08/redisqueue

redisqueue provides a producer and consumer of a queue that uses Redis streams

Language: Go - Size: 32.2 KB - Last synced at: 28 days ago - Pushed at: over 1 year ago - Stars: 134 - Forks: 58

worker-tools/html

HTML templating and streaming response library for Service Worker-like environments such as Cloudflare Workers.

Language: TypeScript - Size: 140 KB - Last synced at: 4 days ago - Pushed at: over 2 years ago - Stars: 71 - Forks: 5

MattiasBuelens/remote-web-streams

Web streams that work across web workers and iframes.

Language: TypeScript - Size: 630 KB - Last synced at: 5 days ago - Pushed at: over 1 year ago - Stars: 83 - Forks: 10

Accenture/mercury

Reference engine for event-driven applications

Language: Java - Size: 11 MB - Last synced at: 29 days ago - Pushed at: 6 months ago - Stars: 83 - Forks: 39

Peckmore/NetEx

A collection of (hopefully!) useful "extensions" to .Net.

Language: C# - Size: 406 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 2 - Forks: 1

TylorS/typed

Web Applications with Effect-TS

Language: TypeScript - Size: 15.5 MB - Last synced at: 15 days ago - Pushed at: 8 months ago - Stars: 297 - Forks: 15

kylefarris/clamscan

A robust ClamAV virus scanning library supporting scanning files, directories, and streams with local sockets, local/remote TCP, and local clamscan/clamdscan binaries (with failover).

Language: JavaScript - Size: 823 KB - Last synced at: about 1 month ago - Pushed at: 8 months ago - Stars: 257 - Forks: 78

YehudaKremer/FlutterCsharpRpc

Execute C# code from Dart (Flutter) application

Language: Dart - Size: 450 KB - Last synced at: 29 days ago - Pushed at: almost 2 years ago - Stars: 52 - Forks: 6

Bodigrim/infinite-list

Infinite lists aka streams

Language: Haskell - Size: 58.6 KB - Last synced at: 10 days ago - Pushed at: about 1 month ago - Stars: 18 - Forks: 4

jhspetersson/packrat

Gatherers library for Java Stream API

Language: Java - Size: 322 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 17 - Forks: 0

shamansir/rpd

:ok_hand: A Minimal Engine for creating Node-Based Visual Programming User Interfaces

Language: JavaScript - Size: 17.7 MB - Last synced at: 6 days ago - Pushed at: about 1 month ago - Stars: 448 - Forks: 46

milk-org/ImageStreamIO

Support for image stream format I/O

Language: C++ - Size: 513 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 5 - Forks: 11

robtimus/stream-utils

Provides utility classes for working with streams

Language: Java - Size: 596 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0

hemicharly/on-demand-archive-process-nodejs

This project demonstrates an example Node.js application, with the goal of applying the power of Node.js stream and pipeline in data processing, aiming to efficiently process large data sets in batches, minimizing memory consumption.

Language: JavaScript - Size: 146 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 1

diemenator/go-chanstreaming

A lightweight library for building concurrent data processing and streaming pipelines using channels

Language: Go - Size: 102 KB - Last synced at: 9 days ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 0

crettazminaglia/Shifting_streams

This repository contains the dataset and R scripts used in the manuscript Shifting Streams: Functional Responses of Macroinvertebrates to Rural and Urban Pressures in Argentina, currently under review.

Language: Jupyter Notebook - Size: 239 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 0

Bios-Marcel/gostream

implementations for eager and lazy streams in golang.

Language: Go - Size: 43 KB - Last synced at: 3 days ago - Pushed at: over 6 years ago - Stars: 3 - Forks: 0

Bios-Marcel/gostreamexample

Example for https://github.com/Bios-Marcel/gostream

Language: Go - Size: 8.79 KB - Last synced at: 3 days ago - Pushed at: over 6 years ago - Stars: 5 - Forks: 0

PedroH183/vigilant-happiness

A high-performance microservice for efficient image compression. Using FastAPI, Celery, Redis Streams, and AWS S3, it automatically processes uploaded images, reduces their size while maintaining quality, and delivers them via a REST API.

Language: Python - Size: 43.9 KB - Last synced at: 22 days ago - Pushed at: about 2 months ago - Stars: 1 - Forks: 0

transcend-io/penumbra

Encrypt/decrypt anything in the browser using streams on background threads.

Language: TypeScript - Size: 6.83 MB - Last synced at: 29 days ago - Pushed at: 6 months ago - Stars: 155 - Forks: 20

CaroBima/apiPeliculasTMDB

Microservicio que consume la api de películas de TMDB. Realizado utilizando Spring Boot

Language: Java - Size: 166 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 0

Anugupta5102/Train-Ticket-Booking

🎫 A Java-based CLI Train Ticket Booking System using Maven, JSON, and BCrypt. Features secure user login, train search, seat booking, and local data storage – ideal for learning and demo purposes.

Size: 17.6 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 0

gabriel-pivoto/RocketSeat_NodeJS_Introduction_Study

Language: JavaScript - Size: 15.6 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 0

react-native-community/fetch Fork of JakeChampion/fetch

A fetch API polyfill for React Native with text streaming support.

Language: JavaScript - Size: 1.24 MB - Last synced at: 19 days ago - Pushed at: about 2 years ago - Stars: 85 - Forks: 12

federicocarboni/eloquent-ffmpeg

High-level API for FFmpeg's Command Line Tools

Language: TypeScript - Size: 20.3 MB - Last synced at: 5 days ago - Pushed at: over 2 years ago - Stars: 87 - Forks: 5

shekharchander/tube_dl

Youtube video downloader and info extractor for python.

Language: Python - Size: 672 KB - Last synced at: 12 days ago - Pushed at: over 3 years ago - Stars: 23 - Forks: 9

freyjasasi/Selenium-Samples

Some simple selenium with Java codes

Size: 125 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 0

stcarrez/ada-util

Ada Utility Library - Composing streams, processes, logs, serialization, encoders and more

Language: Ada - Size: 8.55 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 72 - Forks: 14

ErickWendel/semana-javascript-expert06

JS Expert Week 6.0 Classes - Spotify Radio

Language: JavaScript - Size: 2.58 MB - Last synced at: about 1 month ago - Pushed at: about 3 years ago - Stars: 1,270 - Forks: 201

marleyDip/Node-JS-Practice

Its now practice server-side-programming for comptetive programming...

Language: JavaScript - Size: 753 KB - Last synced at: 13 days ago - Pushed at: about 2 months ago - Stars: 1 - Forks: 0

IBMStreams/streamsx.crossdc-failover

Cross data center failover toolkit.

Language: Java - Size: 936 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 1 - Forks: 1

Level/read-stream

Read from an abstract-level database using Node.js streams.

Language: JavaScript - Size: 103 KB - Last synced at: 2 days ago - Pushed at: about 2 months ago - Stars: 6 - Forks: 1

Turskyi/flutter_clean_architecture_counter

A refactored version of the default Flutter "counter" app, demonstrating The Clean Architecture with reactive state management using streams. This example showcases a maintainable and scalable approach, incorporating immutability, dependency injection, and a clear separation of concerns.

Language: Dart - Size: 1.17 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 0

Turskyi/flutter_onion_architecture_counter

Refactored Flutter counter app showcasing Onion Architecture with streams, immutability, dependency injection, and clear separation of concerns for scalable, maintainable state management.

Language: Dart - Size: 1.62 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 1 - Forks: 0

SQLStreamStore/SQLStreamStore 📦

Stream Store library targeting RDBMS based implementations for .NET

Language: C# - Size: 5.34 MB - Last synced at: 10 days ago - Pushed at: 11 months ago - Stars: 468 - Forks: 127

sebinsua/scrape-twitter

🐦 Access Twitter data without an API key. [DEPRECATED]

Language: JavaScript - Size: 523 KB - Last synced at: 8 days ago - Pushed at: over 6 years ago - Stars: 175 - Forks: 36

Leogendra/Billions-Charts

Take a look at the statistics behind Spotify's Billions Club playlist

Language: JavaScript - Size: 323 KB - Last synced at: 2 days ago - Pushed at: about 2 months ago - Stars: 1 - Forks: 0

denosaurs/log

📜 Dead-simple drop-in logging solution using streams and the native console api

Language: TypeScript - Size: 45.9 KB - Last synced at: 5 days ago - Pushed at: about 1 year ago - Stars: 28 - Forks: 0

ashkrit/corejava

Experiment with performance , concurrency , database and some useless things

Language: Java - Size: 2.66 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 13 - Forks: 4

EricLondon/kafka-log-aggregator

Java Kafka Log Aggregator

Language: Java - Size: 75.2 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 7 - Forks: 6

sbcd90/siddhi-kafka-cep

This is a simple CEP Engine leveraging the Kafka Streams platform

Language: Java - Size: 66.4 KB - Last synced at: about 2 months ago - Pushed at: about 8 years ago - Stars: 16 - Forks: 3

apache/streams

Apache Streams

Language: Java - Size: 142 MB - Last synced at: 7 days ago - Pushed at: about 2 months ago - Stars: 77 - Forks: 45

cdauth/json-stream-es

A streaming JSON parser/stringifier using web streams.

Language: TypeScript - Size: 1.26 MB - Last synced at: 4 days ago - Pushed at: 7 months ago - Stars: 9 - Forks: 2

nanoframework/System.IO.Streams

:package: System.IO.Streams library for .NET nanoFramework.

Language: C# - Size: 188 KB - Last synced at: 3 days ago - Pushed at: 2 months ago - Stars: 2 - Forks: 5

spiral/streams

[READ ONLY] PSR-7 Stream Wrappers. Subtree split of the Spiral Stream component (see spiral/framework)

Language: PHP - Size: 60.5 KB - Last synced at: 29 days ago - Pushed at: 2 months ago - Stars: 1 - Forks: 0

whatwg/compression

Compression Standard

Language: HTML - Size: 1.68 MB - Last synced at: 29 days ago - Pushed at: 2 months ago - Stars: 95 - Forks: 19

adhdtech/DRP

DRP - A websocket subprotocol for declaring and consuming resources

Language: JavaScript - Size: 12.5 MB - Last synced at: 3 days ago - Pushed at: 2 months ago - Stars: 13 - Forks: 0

pjandl/jgp4

Java - Guia do Programador - 4a Edição

Language: Java - Size: 632 KB - Last synced at: 2 months ago - Pushed at: over 2 years ago - Stars: 55 - Forks: 16

zefhub/zef

Toolkit for graph-relational data across space and time

Language: Python - Size: 10.4 MB - Last synced at: 28 days ago - Pushed at: 10 months ago - Stars: 114 - Forks: 2

markrogoyski/itertools-php

PHP Iteration Tools Library

Language: PHP - Size: 969 KB - Last synced at: about 1 month ago - Pushed at: 4 months ago - Stars: 143 - Forks: 13

Wilson-Barbosa/functional-programming-and-streams

Contains a brief discussion on functional programming with examples

Language: Java - Size: 2.93 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0

NativeInstruments/ni-media

NI Media is a C++ library for reading and writing audio streams.

Language: C++ - Size: 30.6 MB - Last synced at: 28 days ago - Pushed at: 10 months ago - Stars: 250 - Forks: 37

thearchitector/datagraph

A framework-agnostic asynchronous data processing library based on dataflows.

Language: Python - Size: 216 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0

willfarrell/datastream

Commonly used stream patterns for Web Streams API and NodeJS Streams

Language: JavaScript - Size: 3.91 MB - Last synced at: 1 day ago - Pushed at: 9 months ago - Stars: 8 - Forks: 2

SpEcHiDe/AnyDLBot

An Open Source GPLv3 All-In-One Telegram Bot

Language: Python - Size: 217 KB - Last synced at: about 1 month ago - Pushed at: over 3 years ago - Stars: 387 - Forks: 1,680

NTDLS/NTDLS.StreamFraming

Stream wrapper (typically TCPIP/NetworkStream) that enables reliable framing, compression, optional encryption and two way communication.

Language: C# - Size: 163 KB - Last synced at: about 1 month ago - Pushed at: 6 months ago - Stars: 0 - Forks: 0

leocavalcante/swoole-futures

⏳ Futures, Streams & Async/Await for PHP's Swoole asynchronous run-time.

Language: PHP - Size: 65.4 KB - Last synced at: 4 days ago - Pushed at: about 5 years ago - Stars: 104 - Forks: 3

bredele/vomit

:mask: A minimal high order function for building user interfaces

Language: JavaScript - Size: 155 KB - Last synced at: 5 days ago - Pushed at: over 8 years ago - Stars: 161 - Forks: 12

jucardi/go-streams

Stream Collections for Go. Inspired in Java 8 Streams and .NET Linq

Language: Go - Size: 89.8 KB - Last synced at: about 2 months ago - Pushed at: over 1 year ago - Stars: 327 - Forks: 25

geniusrabbit/notificationcenter

🚦 notification message abstraction on top of different messaging pipelines (Kafka, NATS, RedisPubSub, etc)

Language: Go - Size: 231 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 3 - Forks: 0

samuel-cardoso/fundamentos-nodejs

Repositório para solidificar os fundamentos do Node.js.

Language: JavaScript - Size: 1.95 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0

ngbox/ng-observe

Angular reactivity streamlined...

Language: TypeScript - Size: 378 KB - Last synced at: 14 days ago - Pushed at: almost 3 years ago - Stars: 70 - Forks: 1

worker-tools/json-stream

Utilities for working with streaming JSON in Worker Environments.

Language: TypeScript - Size: 122 KB - Last synced at: 7 days ago - Pushed at: about 3 years ago - Stars: 15 - Forks: 1

moocf/vector-sum.cuda

The resultant of two vectors, calculated by adding respective components of each vector is called vector sum.

Language: C++ - Size: 45.9 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0

goldenmaza/aveline

The Frontend provides a dynamically generated website with the information provided by the Backend...

Language: JavaScript - Size: 921 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0

NeuropsyOL/RECORDA

Android Recorder for LSL streams in XDF Format

Language: C++ - Size: 18 MB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 7 - Forks: 6

stdlib-js/streams-node

Standard library Node.js streams.

Language: JavaScript - Size: 3.04 MB - Last synced at: 8 days ago - Pushed at: 3 months ago - Stars: 2 - Forks: 0

browserify/stream-splicer

streaming pipeline with a mutable configuration

Language: JavaScript - Size: 38.1 KB - Last synced at: 4 days ago - Pushed at: 6 months ago - Stars: 56 - Forks: 12

Ghurtchu/blabbermouth

live support chat server (currently in dev)

Language: Scala - Size: 35.2 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 2 - Forks: 0

Cornucopia-Swift/CornucopiaStreams

Cornucopia Streams Library

Language: Swift - Size: 119 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 16 - Forks: 4

burakboduroglu/StreamsChallenge

Java Streams

Language: Java - Size: 4.88 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0

ManzDev/awesome-css-art

Design with CSS code, without images!

Size: 1.33 MB - Last synced at: 9 days ago - Pushed at: over 1 year ago - Stars: 90 - Forks: 5

KristofferStrube/Blazor.Streams

A Blazor wrapper for the Streams browser API.

Language: C# - Size: 12 MB - Last synced at: 8 days ago - Pushed at: 8 months ago - Stars: 14 - Forks: 4

sfab07/Streams.ini-GaGa

Webradios favorite pour l'équivalent de radiotray pour Windows dénommé GaGa

Language: Inno Setup - Size: 117 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 1 - Forks: 0

CyberPhoenix90/aurum

Fast and concise declarative DOM rendering library for javascript

Language: TypeScript - Size: 4.39 MB - Last synced at: 9 days ago - Pushed at: 19 days ago - Stars: 17 - Forks: 1

HowProgrammingWorks/Streams

Read, write, transform data streams

Language: JavaScript - Size: 38.1 KB - Last synced at: about 2 months ago - Pushed at: 7 months ago - Stars: 12 - Forks: 7

beryx/streamplify

Java 8 combinatorics-related streams and other utilities

Language: Java - Size: 1.42 MB - Last synced at: about 2 months ago - Pushed at: almost 7 years ago - Stars: 43 - Forks: 14

ErickWendel/editing-videos-nodejs-ffmpeg

editing videos on-demand using Node.js Streams and ffmpeg (pt-br)

Language: JavaScript - Size: 45.2 MB - Last synced at: 3 months ago - Pushed at: over 2 years ago - Stars: 41 - Forks: 12

ErickWendel/webstreams-nodejs-and-browser-tutorial

Como ler 10GB de JSON no frontend sem travar a tela - Webstreams 101 (ptbr)

Language: JavaScript - Size: 745 KB - Last synced at: 3 months ago - Pushed at: over 2 years ago - Stars: 67 - Forks: 24

koss-null/FuncFrog

Stream api (kind of) implementation for go, other useful functions and packages to use go in a functional way

Language: Go - Size: 4.31 MB - Last synced at: 3 days ago - Pushed at: 9 months ago - Stars: 278 - Forks: 9

transcend-io/conflux

Zip/unzip files of any size in the browser using streams.

Language: JavaScript - Size: 6.15 MB - Last synced at: 27 days ago - Pushed at: 6 months ago - Stars: 103 - Forks: 15

floodplainio/floodplain-library

Kotlin based stream processing framework

Language: Java - Size: 66.1 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 8 - Forks: 2

sister-software/spliterator

High-performance delimited data pipeline tools.

Language: TypeScript - Size: 1.48 MB - Last synced at: 14 days ago - Pushed at: 3 months ago - Stars: 2 - Forks: 0

symblai/Symbl-powered-Agora-RTE-app

Build an app with Agora's Real-Time Engagement App Builder so you can add to your calls, meetings, or conferences transcripts and transcription, live captions and live captioning, contextual AI insight such as action-items, follow-ups & questions, vastly enhancing your real-time engagements.

Language: TypeScript - Size: 13 MB - Last synced at: 3 months ago - Pushed at: over 3 years ago - Stars: 18 - Forks: 15

Tornevall/tornelib-php-netcurl

netcurl - githubified mirror used within packagist (final versions lands here). A preconfigured communications library, set to always return requested data in the same format regardless of the base environment. Autodetecting curl, stream libraries xml/soap and RSS amongst some. If you join this project, submit code to https://www.netcurl.org instead.

Language: PHP - Size: 1.34 MB - Last synced at: 8 days ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0

deva666/Peko

Android Library for requesting Permissions with Kotlin Flow

Language: Kotlin - Size: 557 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 153 - Forks: 11

loup-v/streams_channel

For Flutter plugin development: StreamsChannel is inspired from EventChannel. It allows to create streams of events between Flutter and platform side.

Language: Java - Size: 174 KB - Last synced at: 2 months ago - Pushed at: over 3 years ago - Stars: 41 - Forks: 23

bicycle-codes/crypto-stream

Streaming encryption, based on Encrypted Content-Encoding for HTTP (RFC 8188)

Language: TypeScript - Size: 1.24 MB - Last synced at: 24 days ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0

rabestro/sololearn-challenges

Descriptions of SoloLearn Coding Challenges (all 72, including pro) and solutions in C, Java, Python and Ruby

Language: Java - Size: 1.18 MB - Last synced at: 2 months ago - Pushed at: about 3 years ago - Stars: 122 - Forks: 38

jmcamposdev/Java-Book-Exercises

📚 Welcome to the ☕️ code exercise repository for the Paraninfo Programming book by Alfonso Jiménez Martín and Francisco Manuel Pérez Montes (ed. Paraninfo)! 👨‍💻 Improve your coding skills with carefully written and commented exercises 📝, ranging from simple to complex.

Language: Java - Size: 617 KB - Last synced at: 2 months ago - Pushed at: about 2 years ago - Stars: 8 - Forks: 3

react-native-community/fetch Fork of JakeChampion/fetch

SQLStreamStore/SQLStreamStore 📦

nanoframework/Windows.Storage.Streams 📦