Skip to content

Commit

Permalink
Minor update
Browse files Browse the repository at this point in the history
  • Loading branch information
tom10271 committed Apr 27, 2023
1 parent dfef1c9 commit 3a670f5
Showing 1 changed file with 12 additions and 9 deletions.
21 changes: 12 additions & 9 deletions feederConsumer/feederConsumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,19 +4,22 @@ import (
"sync"
)

type Feeders struct {
Count int
Callback func() (interface{}, bool)
}

type Consumers struct {
Count int
Callback func() (interface{}, bool)
}

type FeederConsumer struct {
WaitGroup sync.WaitGroup
DataChannel chan interface{}

Feeders []struct {
Count int
Callback func() (interface{}, bool)
}

Consumers struct {
Count int
Callback func(interface{})
}
Feeders []Feeders
Consumers Consumers
}

func (fc *FeederConsumer) Run() {
Expand Down

0 comments on commit 3a670f5

Please sign in to comment.