sm

type Closable interface {
	IsClosed() bool
	TryClose() bool
}

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

type EnqueueOp = func(any) any

type Loop struct {
	Itemcount int
	Itemtimes int
	// contains filtered or unexported fields
}

type OnFinCB = func()

type OnItemsCB = func(...any)

type Queue interface {
	Start()
	Stop()

	// Enqueue puts an item into this queue
	// it will return directly when if it is an unblocking queue and there has no more free space,
	// and ErrFull will be return to notify the producer.
	Enqueue(any) (any, error)
}

type StateMachine interface {
	Start()
	Stop()
	EnqueueRecevied(any) (any, error)
	EnqueueCheckpoint(any) (any, error)
}