Package rx.observers

Default wrappers and implementations for the base reactive consumer classes and interfaces; utility classes for creating them from callbacks.