listenerSession := event.MustListen(cssConsumeFunc)
defer func() {
	listenerSession.Close()

	fmt.Println("Sum:", cssSum)
}()

var workerPool = splitex.DefaultWorkerPoolWith(NewExampleSplitter(), NewExampleWorkerFactory())

var data = generateData()
var notifyChannel chan<- event.Event = listenerSession.NotifyChannel()

var waitGroup, distributeErr = workerPool.Distribute(data, notifyChannel)
if nil != distributeErr {
	fmt.Println("An error has been occurred during Distribute call:", distributeErr)

	os.Exit(1)
}

waitGroup.Wait()

// ...

// will be executed by workers (see example worker)
func (s *ExampleService) DoSomeWork(data []int) int {
	fmt.Printf("Partial data has been received: %v\n", data)

	var sum int

	for index := range data {
		sum += data[index]
	}

	return sum
}

var cssSum int

// will be executed in a single "collecting" flow
func cssConsumeFunc(e event.Event) {
	fmt.Printf("An event has been received. Type: %d, Payload: %v\n", e.Type, e.Payload)

	var partialSum, isDataTypeExpected = e.Payload.(int)
	if !isDataTypeExpected {
		panic("example: event payload misuse, invalid partial result format")
	}

	cssSum += partialSum
}