RxSci Reference Documentation

ReactiveX operators for data science and machine learning.

This documentation contains the reference of all RxSci operators. For an introduction to RxSci, see the Maki Nage documentation.

Contents:

• Installation
• Get Started
• Operators
  • Base
    • assert_()
    • assert_1()
    • count()
    • distinct()
    • distinct_until_changed()
    • do_action()
    • filter()
    • first()
    • flat_map()
    • from_iterable()
    • group_by()
    • identity()
    • last()
    • map()
    • multiplex()
    • progress()
    • scan()
    • starmap()
    • start_with()
    • take()
    • tee_map()
    • with_latest_from()
  • Error
    • create_error_router()
    • ignore()
    • map()
  • Math
    • max()
    • mean()
    • min()
    • stddev()
    • sum()
    • variance()
    • Distributed
    • Formal
  • Container
    • csv
    • json
    • parquet
  • Data
    • batch()
    • cache()
    • clip()
    • decode()
    • encode()
    • fill_none()
    • lag()
    • roll()
    • sort()
    • split()
    • time_split()
    • to_array()
    • to_deque()
    • to_list()
  • IO
    • read()
    • walk()
    • write()
  • Framing
    • line
    • length prefix
  • Compression
    • gzip
    • zstd
  • State
    • MemoryStore
    • with_memory_store()
    • with_store()

Indices and tables

• Index

• Module Index