module Turbopuffer::Internal::Util

def chain_fused(enum, &blk)

Returns:
  • (Enumerable) -
    Other tags:
      Yieldparam: -

    Parameters:
    • blk (Proc) --
    • enum (Enumerable, nil) --
      Other tags:
        Api: - private
      def chain_fused(enum, &blk)
        iter = Enumerator.new { blk.call(_1) }
        fused_enum(iter) { close_fused!(enum) }
      end