added subscribe/unsubscribe methods to Flow