Welcome to stream2py’s documentation!

Contents:

• stream2py
  • The Rationale
  • How to use
• stream2py.buffer_reader
  • BufferReader
• stream2py.exceptions
  • BufferError
  • BufferOverflowError
  • ConfigurationError
  • InvalidDataError
  • NoDataAvailableError
  • Stream2PyError
  • StreamAlreadyStoppedError
  • StreamNotStartedError
• stream2py.protocols
  • Source
• stream2py.simply
  • mk_stream_buffer()
• stream2py.source_reader
  • SourceReader
• stream2py.sources
• HTTP Response streaming reader with no external dependencies
• stream2py.stream_buffer
  • StreamBuffer
• stream2py.stream_source
  • StreamSource
  • defaulted_values()
• stream2py.tests.test_buffer_reader
  • test_inject_buffer_reader()
• stream2py.tests.test_buffer_reader_blocking
  • test_buffer_reader_blocking()
  • test_buffer_reader_blocking_stops_on_stop_event()
• stream2py.tests.test_buffer_reader_stopiteration
• stream2py.tests.test_lock_sorted_deque
• stream2py.tests.test_quick_source_reader
• stream2py.tests.test_reader_without_context
• stream2py.tests.test_source_reader
• stream2py.tests.test_stream_buffer
• stream2py.tests.test_stream_source
• stream2py.tests.test_util
• stream2py.tests.utils_for_testing
  • RandomFloatSource
  • SimpleSourceReader
  • TenthSecondCounterSourceReader
  • TenthSecondCounterStreamSource
  • is_decreasing()
  • is_increasing()
  • is_monotonic()
  • is_non_decreasing()
  • is_non_increasing()
  • pairwise()
• stream2py.util
  • ContextualizeCall
  • EnterFunctionValidation
  • ExitFunctionValidation
  • Timer
  • TypeValidationError
  • identity()
• stream2py.utility
• stream2py.utility.locked_sorted_deque
  • RWLockSortedDeque
• stream2py.utility.reader_writer_lock
  • RWLock
  • RWLockTestCase
  • Reader
  • Writer
• stream2py.utility.sorted_collection
  • SortedCollection
• stream2py.utility.sorted_deque
  • SortedDeque
• stream2py.utility.typing_hints
  • ComparableType

Indices and tables

• Index

• Module Index

• Search Page

Release: 1.0.43

Last change: Aug 26, 2026