@@ -83,7 +83,9 @@ var DefaultMetadataFunc = func(ctx context.Context) (context.Context, error) {
|
|||||||
|
|
||||||
type hook struct{}
|
type hook struct{}
|
||||||
|
|
||||||
var Hook = &hook{}
|
func NewHook() *hook {
|
||||||
|
return &hook{}
|
||||||
|
}
|
||||||
|
|
||||||
func (w *hook) ServerSubscriber(next server.FuncSubHandler) server.FuncSubHandler {
|
func (w *hook) ServerSubscriber(next server.FuncSubHandler) server.FuncSubHandler {
|
||||||
return func(ctx context.Context, msg server.Message) error {
|
return func(ctx context.Context, msg server.Message) error {
|
||||||
|
Reference in New Issue
Block a user