Twister915

package main

import (
	"context"
	"sync"
)

type fanOutResult[K any, R any] struct {
	Key K
	Result R

Twister915

use std::marker::PhantomData;

pub enum TopK<I, E, K, F, const N: usize> {
    // this TopK has just been created and no data has been computed
    // this is the initial state
    Prepared {
        itr: I,
        f: F,
        _k: PhantomData<K>,
    },

Twister915

package main

import (
	"context"
	"io"
	"log/slog"
	"net/http"
	"os"
	"os/signal"
	"path"