| 64 | } |
| 65 | |
| 66 | func NewClientIPC(logger logging.Logger, sockConn io.ReadWriteCloser, handler http.Handler, onServerClosed func(error), option ...Option) (io.Closer, *http.Client, error) { |
| 67 | cfg := yamux.DefaultConfig() |
| 68 | cfg.Logger = &loggerWrapper{logger} |
| 69 | cfg.LogOutput = nil |
| 70 | session, err := yamux.Client(sockConn, cfg) |
| 71 | if err != nil { |
| 72 | return nil, nil, fmt.Errorf("creating yamux client: %w", err) |
| 73 | } |
| 74 | i, c := newMuxedIPC(logger, session, handler, onServerClosed, option...) |
| 75 | return i, c, nil |
| 76 | } |
| 77 | |
| 78 | func NewServerIPC(logger logging.Logger, sockConn io.ReadWriteCloser, handler http.Handler, onServerClosed func(error), option ...Option) (io.Closer, *http.Client, error) { |
| 79 | cfg := yamux.DefaultConfig() |