fanin

type FullnessSynchronizer struct {
	// contains filtered or unexported fields
}

type IntervalSynchronizer struct {
	// contains filtered or unexported fields
}

type Node[T any] struct {
	// contains filtered or unexported fields
}

type PairMakerFunc[A, B, Res any] func(A, B) (Res, error)

type PairNode[A, B, Res any] struct {
	// contains filtered or unexported fields
}

type Synchronizer interface {
	Add(idx int, val any) []any
	Close() error
}

type SynchronizerBuilder func(items int) (Synchronizer, error)

type TimestampSynchronizer struct {
	// contains filtered or unexported fields
}

type TripletMakerFunc[A, B, C, Res any] func(A, B, C) (Res, error)

type TripletNode[A, B, C, Res any] struct {
	// contains filtered or unexported fields
}

type WithTimestamp interface {
	Timestamp() time.Duration
}