streamxclient

Documentation

Index

• func InvokeStream[Req, Res any](ctx context.Context, cli client.Client, smode serviceinfo.StreamingMode, ...) (context.Context, *streamx.GenericClientStream[Req, Res], error)
• func WithProvider(pvd streamx.ClientProvider) internal_client.Option
• func WithStreamRecvMiddleware(smw streamx.StreamRecvMiddleware) internal_client.Option
• func WithStreamRecvTimeout(timeout time.Duration) internal_client.Option
• func WithStreamSendMiddleware(smw streamx.StreamSendMiddleware) internal_client.Option

Functions

func InvokeStream

func InvokeStream[Req, Res any](
	ctx context.Context, cli client.Client, smode serviceinfo.StreamingMode, method string,
	req *Req, res *Res, callOptions ...streamxcallopt.CallOption,
) (context.Context, *streamx.GenericClientStream[Req, Res], error)

InvokeStream create a new client stream and wrapped related middlewares

func WithProvider

func WithProvider(pvd streamx.ClientProvider) internal_client.Option

Deprecated: Note that it maybe refactor in the next version

func WithStreamRecvMiddleware

func WithStreamRecvMiddleware(smw streamx.StreamRecvMiddleware) internal_client.Option

WithStreamRecvMiddleware add recv middleware

func WithStreamRecvTimeout

func WithStreamRecvTimeout(timeout time.Duration) internal_client.Option

WithStreamRecvTimeout add recv timeout for stream.Recv function

func WithStreamSendMiddleware

func WithStreamSendMiddleware(smw streamx.StreamSendMiddleware) internal_client.Option

WithStreamSendMiddleware add send middleware