The Flow.Subscriber interface