Method Run

IceFireDB-PubSub/proxy/proxy.go:139–147

(ctx context.Context, errSignal chan error)

}

func (p *Proxy) Run(ctx context.Context, errSignal chan error) {
	go func() {
		select {
		case <-ctx.Done():
			_ = p.server.Close()
		}
	}()
	_ = p.server.ListenServeAndSignal(errSignal)
}