༄ streamable docs

Contents

• API Reference
  • ༄ streamable
    • stream
      • stream.__add__()
      • stream.__aiter__()
      • stream.__await__()
      • stream.__call__()
      • stream.__eq__()
      • stream.accept()
      • stream.buffer()
      • stream.cast()
      • stream.catch()
      • stream.do()
      • stream.filter()
      • stream.flatten()
      • stream.group()
      • stream.map()
      • stream.observe()
      • stream.pipe()
      • stream.skip()
      • stream.take()
      • stream.throttle()
      • stream.source
      • stream.upstream
    • star()
    • Observation
      • Observation.__str__()
      • Observation.count()
      • Observation.index()
      • Observation.elapsed
      • Observation.elements
      • Observation.errors
      • Observation.subject
    • ClosableAsyncIterator
      • ClosableAsyncIterator.aclose()