func ServeDirect(
	ctx context.Context, server *rpc.Server, stream io.ReadWriteCloser, remote *proto.RawNodeID,
) {
	subctx, cancelFunc := context.WithCancel(ctx)
	defer cancelFunc()
	nodeAwareCodec := NewNodeAwareServerCodec(subctx, utils.GetMsgPackServerCodec(stream), remote)
	server.ServeCodec(nodeAwareCodec)
}
ServeDirect serves data stream directly.
package rpc
import (
	"context"
	"io"
	"net/rpc"
	"github.com/SQLess/SQLess/proto"
	"github.com/SQLess/SQLess/utils"
)