22 lines
355 B
Go
22 lines
355 B
Go
|
package event2
|
||
|
|
|
||
|
|
import "context"
|
||
|
|
|
||
|
|
type Consumer struct {
|
||
|
|
driver DriverInterface
|
||
|
|
}
|
||
|
|
|
||
|
|
func (c *Consumer) Receive(ctx context.Context) *event {
|
||
|
|
return c.driver.Get()
|
||
|
|
}
|
||
|
|
|
||
|
|
func (c *Consumer) NewEvent(name string) *event {
|
||
|
|
return c.driver.NewEvent(name)
|
||
|
|
}
|
||
|
|
|
||
|
|
func NewConsumer(driver DriverInterface) ConsumerInterface {
|
||
|
|
return &Consumer{
|
||
|
|
driver: driver,
|
||
|
|
}
|
||
|
|
}
|