genericclient

type BidiStreamingClient interface {
	// Send sends a message to the server.
	Send(ctx context.Context, req interface{}) error
	// Recv receives a message from the server.
	Recv(ctx context.Context) (interface{}, error)
	// Header inherits from the underlying streaming.ClientStream.
	Header() (streaming.Header, error)
	// Trailer inherits from the underlying streaming.ClientStream.
	Trailer() (streaming.Trailer, error)
	// CloseSend inherits from the underlying streaming.ClientStream.
	CloseSend(ctx context.Context) error
	// Context inherits from the underlying streaming.ClientStream.
	Context() context.Context
	// Streaming returns the underlying streaming.ClientStream.
	Streaming() 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 sends a message to the server.
	Send(ctx context.Context, req interface{}) error
	// CloseAndRecv closes the send direction of the stream and returns the response from the server.
	CloseAndRecv(ctx context.Context) (interface{}, error)
	// Header inherits from the underlying streaming.ClientStream.
	Header() (streaming.Header, error)
	// Trailer inherits from the underlying streaming.ClientStream.
	Trailer() (streaming.Trailer, error)
	// CloseSend inherits from the underlying streaming.ClientStream.
	CloseSend(ctx context.Context) error
	// Context inherits from the underlying streaming.ClientStream.
	Context() context.Context
	// Streaming returns the underlying streaming.ClientStream.
	Streaming() streaming.ClientStream
}

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

type ServerStreamingClient interface {
	// Recv receives a message from the server.
	Recv(ctx context.Context) (interface{}, error)
	// Header inherits from the underlying streaming.ClientStream.
	Header() (streaming.Header, error)
	// Trailer inherits from the underlying streaming.ClientStream.
	Trailer() (streaming.Trailer, error)
	// CloseSend inherits from the underlying streaming.ClientStream.
	CloseSend(ctx context.Context) error
	// Context inherits from the underlying streaming.ClientStream.
	Context() context.Context
	// Streaming returns the underlying streaming.ClientStream.
	Streaming() streaming.ClientStream
}