mybus

type BusPublisher interface {
	Publish(key string, args ...any)
	HasCallback(key string) bool
	WaitAsync()
}

type BusSubscriber interface {
	Subscribe(key string, fn any) error
	SubscribeAsync(key string, fn any) error
	SubscribeOnce(key string, fn any) error
	SubscribeOnceAsync(key string, fn any) error
	Unsubscribe(key string, fn any)
}

type ClientArg struct {
	Args  []interface{}
	Topic string
}

type ClientBus interface {
	RpcBus
	Subscribe(key string, fn any, serverAddr, serverPath string) error
	SubscribeOnce(key string, fn any, serverAddr, serverPath string) error
	ClientService() *ClientService
}

type ClientService struct {
	// contains filtered or unexported fields
}

type EventBus interface {
	BusSubscriber
	BusPublisher
}

type NetworkBus interface {
	ClientBus
	ServerBus
}

type NetworkService struct {
	// contains filtered or unexported fields
}

type RpcBus interface {
	Start() error
	Stop()
	ServerAddr() string
	ServerPath() string
	Bus() EventBus
}

type ServerBus interface {
	RpcBus
	RegisterType(param any)
	HasClientSubscribed(arg *SubscribeArg) bool
	ClientSubscribed() *mymap.MultiMap[string, *SubscribeArg]
	RPCCallback(arg *SubscribeArg) func(args ...interface{})
	ServerService() *ServerService
}

type ServerService struct {
	// contains filtered or unexported fields
}

type SubscribeArg struct {
	ClientAddr    string
	ClientPath    string
	ServiceMethod string
	SubscribeType SubscribeType
	Topic         string
}

type SubscribeType int