streamxserver

Documentation

Index

• func InvokeBidiStreamHandler[Req, Res any](ctx context.Context, reqArgs streamx.StreamReqArgs, ...) (err error)
• func InvokeClientStreamHandler[Req, Res any](ctx context.Context, reqArgs streamx.StreamReqArgs, ...) (err error)
• func InvokeServerStreamHandler[Req, Res any](ctx context.Context, reqArgs streamx.StreamReqArgs, ...) (err error)
• func InvokeUnaryHandler[Req, Res any](ctx context.Context, reqArgs streamx.StreamReqArgs, ...) error
• func WithProvider(provider streamx.ServerProvider) server.Option
• func WithStreamRecvMiddleware(mw streamx.StreamRecvMiddleware) server.Option
• func WithStreamSendMiddleware(mw streamx.StreamSendMiddleware) server.Option

Functions

func InvokeBidiStreamHandler

func InvokeBidiStreamHandler[Req, Res any](
	ctx context.Context,
	reqArgs streamx.StreamReqArgs, resArgs streamx.StreamResArgs,
	methodHandler streamx.BidiStreamingHandler[Req, Res],
) (err error)

func InvokeClientStreamHandler

func InvokeClientStreamHandler[Req, Res any](
	ctx context.Context,
	reqArgs streamx.StreamReqArgs, resArgs streamx.StreamResArgs,
	methodHandler streamx.ClientStreamingHandler[Req, Res],
) (err error)

func InvokeServerStreamHandler

func InvokeServerStreamHandler[Req, Res any](
	ctx context.Context,
	reqArgs streamx.StreamReqArgs, resArgs streamx.StreamResArgs,
	methodHandler streamx.ServerStreamingHandler[Req, Res],
) (err error)

func InvokeUnaryHandler

func InvokeUnaryHandler[Req, Res any](
	ctx context.Context,
	reqArgs streamx.StreamReqArgs, resArgs streamx.StreamResArgs,
	methodHandler streamx.UnaryHandler[Req, Res],
) error

func WithProvider

func WithProvider(provider streamx.ServerProvider) server.Option

Deprecated: Note that it maybe refactor in the next version

func WithStreamRecvMiddleware

func WithStreamRecvMiddleware(mw streamx.StreamRecvMiddleware) server.Option

WithStreamRecvMiddleware add recv middleware

func WithStreamSendMiddleware

func WithStreamSendMiddleware(mw streamx.StreamSendMiddleware) server.Option

WithStreamSendMiddleware add send middleware