package gateway

import (
	"context"
	"sig-pub/api/pb"

	"google.golang.org/grpc"
)

type GatewayPostalGrpcServer struct {
	pb.UnimplementedGatewayPostalServer
}

func NewGatewayGrpcServer() *GatewayPostalGrpcServer {
	return &GatewayPostalGrpcServer{}
}

// DeliverStream 使用流连续发送数据
func (svr *GatewayPostalGrpcServer) DeliverStream(req grpc.ClientStreamingServer[pb.ReqDeliver, pb.ResDeliver]) (err error) {

	return nil
}

// Deliver 发送一次数据
func (svr *GatewayPostalGrpcServer) Deliver(ctx context.Context, req *pb.ReqDeliver) (*pb.ResDeliver, error) {

	return nil, nil
}

// DeliverBatch 批量发送数据
func (svr *GatewayPostalGrpcServer) DeliverBatch(ctx context.Context, req *pb.ReqDeliverBatch) (res *pb.ResDeliver, err error) {

	return nil, nil
}