[Bug]: p.Register undefined (type *fission.Distributor has no field or method Register)

[tiansin]

Observed behavior

eventbus/bus.go

Line 76 in 6bc1963

p.Register(toDistCtx(newSyncDistribution(handler)))

Expected behavior

eventbus/bus.go

Line 76 in 6bc1963

p.Register(toDistCtx(newSyncDistribution(handler)))

Host environment

No response

[danielhookx]

Thank you for reporting this issue. Could you provide more complete context information, including:

1. Code for initializing the instance
2. Full printout of the error context

[tiansin]

@danielhookx Updating the library github.com/danielhookx/fission from v0.1.0 to v1.0.0 causes this issue, while using v0.1.0 works without any problems.

[yuelwish]

版本

github.com/danielhookx/eventbus v0.0.0-20240409135312-6bc196392845
github.com/danielhookx/fission v1.0.0 

package main

import (
	"github.com/danielhookx/eventbus"
)

func calculator(a int, b int) {
	fmt.Printf("%d\n", a + b)
}

func main() {
    bus := eventbus.New()
    bus.Subscribe("calculator", calculator);
    bus.Publish("calculator", 10, 20);
}

就主页这个 demo 都跑不起来，这是报错信息

# github.com/danielhookx/eventbus
/home/apps/GoPath/pkg/mod/github.com/danielhookx/eventbus@v0.0.0-20240409135312-6bc196392845/bus.go:59:34: not enough arguments in call to bus.dm.PutDistributor
	have (uintptr, func(key any) fission.Distribution)
	want (context.Context, any, fission.CreateDistributionHandleFunc)
/home/apps/GoPath/pkg/mod/github.com/danielhookx/eventbus@v0.0.0-20240409135312-6bc196392845/bus.go:60:4: p.Register undefined (type *fission.Distributor has no field or method Register)
/home/apps/GoPath/pkg/mod/github.com/danielhookx/eventbus@v0.0.0-20240409135312-6bc196392845/bus.go:75:34: not enough arguments in call to bus.dm.PutDistributor
	have (uintptr, func(key any) fission.Distribution)
	want (context.Context, any, fission.CreateDistributionHandleFunc)
/home/apps/GoPath/pkg/mod/github.com/danielhookx/eventbus@v0.0.0-20240409135312-6bc196392845/bus.go:76:4: p.Register undefined (type *fission.Distributor has no field or method Register)
/home/apps/GoPath/pkg/mod/github.com/danielhookx/eventbus@v0.0.0-20240409135312-6bc196392845/bus.go:87:34: not enough arguments in call to bus.dm.PutDistributor
	have (any, fission.CreateDistributionHandleFunc)
	want (context.Context, any, fission.CreateDistributionHandleFunc)
/home/apps/GoPath/pkg/mod/github.com/danielhookx/eventbus@v0.0.0-20240409135312-6bc196392845/bus.go:88:4: p.Register undefined (type *fission.Distributor has no field or method Register)
/home/apps/GoPath/pkg/mod/github.com/danielhookx/eventbus@v0.0.0-20240409135312-6bc196392845/netbus.go:188:9: cannot use func(key any) fission.Distribution {…} (value of type func(key any) fission.Distribution) as fission.CreateDistributionHandleFunc value in return statement

我看了原因是因为类型不匹配

// 回调函数的定义是定义：
type CreateDistributionHandleFunc func(ctx context.Context, key any) Distribution

// 实际上传入的值是 
// eventbus@v0.0.0-20240409135312-6bc196392845/bus.go:59
p := bus.dm.PutDistributor(key, createEventBusRepeatDist)

// createEventBusRepeatDist 的定义是
func createEventBusRepeatDist(key any) fission.Distribution {
	return newRepeatDistribution(key)
}

// 这里缺少了上下文导致的类型不匹配