stream observer