mirror of
https://github.com/go-kratos/kratos.git
synced 2026-05-16 09:48:28 +02:00
remove publish async (#811)
This commit is contained in:
@@ -23,7 +23,6 @@ type Handler func(context.Context, Event) error
|
|||||||
// to queue.
|
// to queue.
|
||||||
type Publisher interface {
|
type Publisher interface {
|
||||||
Publish(ctx context.Context, event Event) error
|
Publish(ctx context.Context, event Event) error
|
||||||
PublishAsync(ctx context.Context, event Event, callback func(err error)) error
|
|
||||||
Close() error
|
Close() error
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user