package sdk

import (
	"analysis/work"
	"context"
)

// EFExtract engine face extract
type EFExtract struct {
	threads int
}

// NewEFExtract new
func NewEFExtract(thread int) *EFExtract {
	return &EFExtract{thread}
}

// Init impl interface
func (e *EFExtract) Init() bool {

	return true
}

// Run impl interface
func (e *EFExtract) Run(ctx context.Context, in <-chan work.MsgRS, out chan<- work.MsgRS, typ string) {

	for {
		select {
		case <-ctx.Done():
			return
		default:
			rMsg := <-in

			ejectResult(nil, rMsg, out)
		}
	}
}