Function MemTransportPipe

codersdk/drpcsdk/transport.go:85–92

()

}

func MemTransportPipe() (drpc.Conn, net.Listener) {
	m := &memDRPC{
		closed: make(chan struct{}),
		l:      fasthttputil.NewInmemoryListener(),
	}

	return m, m.l
}

type memDRPC struct {
	closeOnce sync.Once