func ContextWithPublisher(ctx context.Context, pub Publisher) context.Context {
	return context.WithValue(ctx, KeyPublisher, pub)
}
func ContextWithPublisher(ctx context.Context, pub Publisher) context.Context {
	return context.WithValue(ctx, KeyPublisher, pub)
}
// ContextWithPublisher constructs new context with bus.