Class StreamPubSubProvider.Subscriber