Class FlowableFromStream.StreamConditionalSubscription<T>