Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type RpcMultiplexer ¶
type RpcMultiplexer struct {
// contains filtered or unexported fields
}
func NewRpcMultiplexer ¶
func NewRpcMultiplexer(rw types.RpcReadWriter) *RpcMultiplexer
func (*RpcMultiplexer) CallUnaryMethod ¶
func (*RpcMultiplexer) Close ¶
func (rm *RpcMultiplexer) Close()
func (*RpcMultiplexer) NewStreamReadWriter ¶
func (rm *RpcMultiplexer) NewStreamReadWriter( ctx context.Context, ) (uint64, types.RpcReadWriter, func(), error)
NewStreamReadWriter returns a new goat.RpcReadWriter which will read and write Rpcs using the returned id. Also returns a teardown function which will close the stream.
Click to show internal directories.
Click to hide internal directories.