Function newMuxedIPC

x/ipc/ipc.go:133–158

(logger logging.Logger, session *yamux.Session, handler http.Handler, onClose func(error), option ...Option)

}

func newMuxedIPC(logger logging.Logger, session *yamux.Session, handler http.Handler, onClose func(error), option ...Option) (*ipcImpl, *http.Client) {
	// Note: Calling session.Close() needs to be done as the very last step as it shuts down all IPC!

	cfg := &cfg{shutdownTimeout: defaultShutdownTimeout}
	for _, o := range option {
		cfg = o(cfg)
	}
	server := newIpcServer(session, handler, func(err error) error {
		if onClose != nil {
			onClose(err)
		}
		return session.Close()
	})
	c := createYamuxedClient(session)
	return &ipcImpl{
		server: server,
		teardown: sync.OnceValue(func() error {
			_ = session.GoAway()
			c.CloseIdleConnections()
			waitForClientToDisconnect(logger, session, cfg.shutdownTimeout)
			err := server.server.Close()
			<-server.done
			return errors.Join(err, server.err)
		}),
	}, c
}

func waitForClientToDisconnect(logger logging.Logger, s *yamux.Session, t time.Duration) {
	timeout := time.After(t)