grpc

type ClientBinding struct {
	Unary       endpoint.Unary[service.EchoRequest, service.EchoResponse]
	InnerStream endpoint.InnerStream[service.EchoRequest, service.EchoResponse]
	OuterStream endpoint.OuterStream[service.EchoRequest, service.EchoResponse]
	BiStream    endpoint.BiStream[service.EchoRequest, service.EchoResponse]
}

type ServerBinding struct {
	pb.UnimplementedEchoServer
	// contains filtered or unexported fields
}

type Service interface {
	Once(ctx context.Context, req service.EchoRequest) (service.EchoResponse, error)
	Inner(ctx context.Context, req service.EchoRequest) (endpoint.Receive[service.EchoResponse], error)
	Outer(ctx context.Context, receiver <-chan service.EchoRequest) (service.EchoResponse, error)
	Bi(ctx context.Context, receiver <-chan service.EchoRequest) (endpoint.Receive[service.EchoResponse], error)
}