Function DefaultDRPCOptions

codersdk/drpcsdk/transport.go:23–32

(options *drpcmanager.Options)

)

func DefaultDRPCOptions(options *drpcmanager.Options) drpcmanager.Options {
	if options == nil {
		options = &drpcmanager.Options{}
	}

	if options.Reader.MaximumBufferSize == 0 {
		options.Reader.MaximumBufferSize = MaxMessageSize
	}
	return *options
}

// MultiplexedConn returns a multiplexed dRPC connection from a yamux Session.
func MultiplexedConn(session *yamux.Session) drpc.Conn {