Class SubscriberSink<In>