Versions in this module Expand all Collapse all v0 v0.0.5 May 11, 2026 Changes in this version + type ClientBidiStreamingServer struct + func NewClientBidiStreamingServer[Req any, Res any](stream grpc.BidiStreamingServer[Req, Res], reqCallback ReqCallback[Req], ...) *ClientBidiStreamingServer[Req, Res] + func (client *ClientBidiStreamingServer[Req, Res]) Process(ctx context.Context) error + func (client *ClientBidiStreamingServer[Req, Res]) Send(message *Res) error + type ClientServerStreamingClient struct + func NewClientServerStreamingClient[Res any](stream grpc.ServerStreamingClient[Res], reqCallback ReqCallback[Res], ...) *ClientServerStreamingClient[Res] + func (client *ClientServerStreamingClient[Res]) Process(ctx context.Context) error + type ClientServerStreamingServer struct + func NewClientServerStreamingServer[Res any](stream grpc.ServerStreamingServer[Res], bufferSize uint32) *ClientServerStreamingServer[Res] + func (client *ClientServerStreamingServer[Res]) Process(ctx context.Context) error + func (client *ClientServerStreamingServer[Res]) Send(message *Res) error + type ReqCallback func(ctx context.Context, req *Req) error v0.0.3 Apr 18, 2026 Changes in this version + var MessageChanClosedError = errors.New("message channel is closed") + var MessageChanFullError = errors.New("message channel is full") + var SendMessageError = errors.New("send message error") + type Client struct + func NewClient[T any](grpcClient grpc.ServerStreamingServer[T], bufferSize uint32) *Client[T] + func (client *Client[T]) Process(ctx context.Context) error + func (client *Client[T]) Send(message *T) error
Go to main page