fn stream()

in src/reporter/grpc.rs [511:527]

• 15 lines of code
• 2 McCabe index (conditional complexity)

    fn stream(&self) -> Option<impl Stream<Item = I>> {
        if self.is_closed.load(Ordering::Relaxed) {
            return None;
        }

        let is_closed = self.is_closed.clone();
        let receiver = self.receiver.clone();

        Some(
            ReceiveFromStream {
                receiver,
                is_closed,
            }
            .timeout(Duration::from_secs(30))
            .map_while(|item| item.ok()),
        )
    }