Index

A

accept() (streamable.stream method)

B

buffer() (streamable.stream method)

C

cast() (streamable.stream method)

catch() (streamable.stream method) count() (streamable.Observation method)

D

do() (streamable.stream method)

E

elapsed (streamable.Observation attribute)

elements (streamable.Observation attribute) errors (streamable.Observation attribute)

F

filter() (streamable.stream method)

flatten() (streamable.stream method)

G

group() (streamable.stream method)

I

index() (streamable.Observation method)

M

map() (streamable.stream method)

O

Observation (class in streamable)

observe() (streamable.stream method)

P

pipe() (streamable.stream method)

S

skip() (streamable.stream method) source (streamable.stream property)

star() (in module streamable) stream (class in streamable) subject (streamable.Observation attribute)

T

take() (streamable.stream method)

throttle() (streamable.stream method)

U

upstream (streamable.stream property)