futura.stream.common
Defines a common subset of functions and hepers that works with all kind of subscription objects.
proxy-subscriber
(proxy-subscriber xform subscriber)Create a proxy subscriber.
The main purpose of this proxy is apply some kind of transformations to the proxied publisher using transducers.
subscribe
(subscribe p)Create a subscription to the given publisher instance.
The returned subscription does not consumes the publisher data until is requested.