1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
package component
import (
"context"
"github.com/johnandersen777/socialweb-computer-kcp/internal/bus"
contract "github.com/johnandersen777/socialweb-computer-kcp/internal/contract/component"
)
type HandlerRegistry = bus.Bus
type Handlers = bus.Bus
type StreamHandler = bus.StreamHandler
const DefaultHandlerName = bus.DefaultHandlerName
var (
ErrNoHandler = bus.ErrNoHandler
ErrNoStream = bus.ErrNoStream
ErrHandlersStopped = bus.ErrHandlersStopped
ErrLinkDenied = bus.ErrLinkDenied
)
func NewHandlerRegistry(ctx context.Context) *HandlerRegistry {
return bus.New(ctx)
}
func NewHandlers(ctx context.Context) *HandlerRegistry {
return bus.New(ctx)
}
func WithCaller(ctx context.Context, key Key) context.Context {
return bus.WithCaller(ctx, key.Ref())
}
func CallerFrom(ctx context.Context) (Key, bool) {
caller, ok := bus.CallerFrom(ctx)
if !ok {
return Key{}, false
}
return contract.KeyOf(caller.Ref), true
}
