genericclient

type BidiStreamingClient interface {
	Send(ctx context.Context, req interface{}) error
	Recv(ctx context.Context) (interface{}, error)
	streaming.ClientStream
}

type BidirectionalStreaming interface {
	streaming.Stream
	Send(req interface{}) error
	Recv() (resp interface{}, err error)
}

type Client interface {
	generic.Closer

	// GenericCall generic call
	GenericCall(ctx context.Context, method string, request interface{}, callOptions ...callopt.Option) (response interface{}, err error)
	// ClientStreaming creates an implementation of ClientStreamingClient
	ClientStreaming(ctx context.Context, method string, callOptions ...streamcall.Option) (ClientStreamingClient, error)
	// ServerStreaming creates an implementation of ServerStreamingClient
	ServerStreaming(ctx context.Context, method string, req interface{}, callOptions ...streamcall.Option) (ServerStreamingClient, error)
	// BidirectionalStreaming creates an implementation of BidiStreamingClient
	BidirectionalStreaming(ctx context.Context, method string, callOptions ...streamcall.Option) (BidiStreamingClient, error)
}

type ClientStreaming interface {
	streaming.Stream
	Send(req interface{}) error
	CloseAndRecv() (resp interface{}, err error)
}

type ClientStreamingClient interface {
	Send(ctx context.Context, req interface{}) error
	CloseAndRecv(ctx context.Context) (interface{}, error)
	streaming.ClientStream
}

type ServerStreaming interface {
	streaming.Stream
	Recv() (resp interface{}, err error)
}

type ServerStreamingClient interface {
	Recv(ctx context.Context) (interface{}, error)
	streaming.ClientStream
}