defer_closing

in lib/openai/internal/type/base_stream.rb [25:44]

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

          def defer_closing(stream) = ->(_id) { OpenAI::Internal::Util.close_fused!(stream) }
        end

        
        def close = OpenAI::Internal::Util.close_fused!(@iterator)

        
        
        
        private def iterator = (raise NotImplementedError)

        
        
        
        
        def each(&blk)
          unless block_given?
            raise ArgumentError.new("A block must be given to ##{__method__}")
          end