Finally figured out this Reactive X subject thing...

rxpy_multiple_subscriptions.py

import rx

obs = rx.Observable.range(0,10)
sub = rx.subjects.Subject()

square = sub.map(
	lambda x: 'i am square: {}'.format(x**2)
)
cube = sub.map(
	lambda x: 'i am cube: {}'.format(x**3)
)

square.subscribe(print)
cube.subscribe(print)

obs.subscribe(sub)