Define action to take based on source observable