stdlibx.streams package

class stdlibx.streams.Disposable(*args, **kwargs)

Bases: Protocol

dispose()

Return type:

None

class stdlibx.streams.Observable(*args, **kwargs)

Bases: Protocol[T_co]

apply(func)

Parameters:

func (Callable[[Observable[T_co]], U_contra])

Return type:

U_contra

subscribe(func)

Parameters:

func (Callable[[T_co], None])

Return type:

Disposable

class stdlibx.streams.Observer(*args, **kwargs)

Bases: Protocol[U_contra]

push(val)

Parameters:

val (U_contra)

Return type:

None

class stdlibx.streams.Subject(initial, /)

Bases: ObservableBase[T]

Parameters:

initial (T)

push(val)

Parameters:

val (T | Callable[[T], T])

Return type:

None

subscribe(func)

Parameters:

func (Callable[[T], None])

Return type:

Disposable

stdlibx.streams.as_observable(value)

Parameters:

value (Observable[T] | T)

Return type:

Observable[T]

Subpackages

• stdlibx.streams.fn package
  • as_tuple()
  • combine()
  • distinct()
  • for_()
  • if_()
  • is_()
  • is_not_none()
  • map_()
  • start_with()
  • Submodules
    • stdlibx.streams.fn.base module
      • as_tuple()
      • combine()
      • distinct()
      • for_()
      • if_()
      • is_()
      • is_not_none()
      • map_()
      • start_with()
• stdlibx.streams.methods package
  • as_tuple()
  • combine()
  • distinct()
  • for_()
  • if_()
  • is_()
  • is_not_none()
  • map_()
  • start_with()
  • Submodules
    • stdlibx.streams.methods.base module
      • as_tuple()
      • combine()
      • distinct()
      • for_()
      • if_()
      • is_()
      • is_not_none()
      • map_()
      • start_with()

Submodules

• stdlibx.streams.utils module
  • as_observable()