fn active_event_stream( stream: Subscription<Event>, ) -> Either<Empty<Result<Event, Error>>, Fuse<Subscription<Event>>> ⓘ