streamerate

library1.2.11pypypi✓ verified 84d ago

streamerate is a fluent and expressive Python library for chainable iterable processing, inspired by Java 8 streams. It provides lazy evaluation, parallel execution options, and a rich set of operations. Current version 1.2.11 requires Python >=3.10 and <4.0. It is actively maintained on GitHub.

data

pip install streamerate

github ↗package ↗

INSTALL

IMPORT

SIG · STREAMERATE

streamerate

datapythonv1.2.11

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

stream

✓ from streamerate import stream

✗ from streamerate.streams import stream

The module has changed; stream is now directly in the top-level package.

Creates a stream from a list, filters elements greater than 2, maps each to double, and collects to a list.

from streamerate import stream # Create a stream from a list and apply operations result = stream([1, 2, 3, 4, 5])\ .filter(lambda x: x > 2)\ .map(lambda x: x * 2)\ .to_list() print(result) # [6, 8, 10]

Debug

Known issues

breakingIf you import from 'streamerate.streams' (old import), the module no longer exists. All public API is now under 'streamerate' directly.

fix

Change 'from streamerate.streams import stream' to 'from streamerate import stream'.

affects: >=1.0.0

gotchastream operations are lazy: they are not executed until a terminal operation (like to_list(), count(), etc.) is called. Repeated terminal operations on the same stream will raise a ValueError because the stream can only be operated upon once.

fix

Store the terminal result and reuse it, or recreate the stream.

affects: all

deprecatedThe 'parallel' parameter in stream() is deprecated in favor of explicit parallel operations like .parallel() method.

fix

Use .parallel() on the stream instead of passing parallel=True to stream().

affects: >=1.2.0

Errors

Common errors & fixes

ImportError: cannot import name 'stream' from 'streamerate'

Old import path 'from streamerate.streams import stream' no longer works.

fix

Use 'from streamerate import stream'.

ValueError: This stream can only be operated upon once

A terminal operation was called on a stream that has already been consumed.

fix

Do not reuse the same stream after a terminal operation; create a new stream if needed.

TypeError: stream() got an unexpected keyword argument 'parallel'

The parallel parameter in stream() constructor was removed in later versions.

fix

Remove the parallel argument and use .parallel() method on the stream.

Upgrade

Version history

1.2.11latest on PyPI · released Apr 14, 2026

Audit

Dependencies

No dependency data recorded yet.

Agent activity

7 hits · last 30 days

node

OpenAI (training)

Resources

githubhttps://github.com/asuiu/streamerate ↗

packagehttps://pypi.org/project/streamerate/ ↗