Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type StreamOperation ¶
type StreamOperation = internal.StreamOperation
func WrapStreamOperation ¶
func WrapStreamOperation( method string, req proto.Message, resp StreamOperationResponse, p func(error), ) StreamOperation
type StreamOperationResponse ¶
type StreamOperationResponse = internal.StreamOperationResponse
func UnwrapStreamOperation ¶
func UnwrapStreamOperation(op StreamOperation) ( method string, req proto.Message, resp StreamOperationResponse, processor func(error), )
Click to show internal directories.
Click to hide internal directories.