Categorygithub.com/bpfs/defsutilsnetwork
package
2.0.1+incompatible
Repository: https://github.com/bpfs/defs.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
10
Dependents
2
Files
193 SLOC

# Functions

SendStream 向指定的节点发送流消息 参数: - protocol: 协议 - genre: 类型 - receiver: 接收方ID - data: 发送的内容 返回: - *streams.ResponseMessage: 响应消息 - error: 错误信息.
SendStreamWithExistingStream 使用已存在的流发送消息 参数: - stream: network.Stream 已经建立的流 - data: []byte 要发送的数据 返回: - *streams.ResponseMessage: 响应消息 - error: 错误信息.
SendStreamWithReader 使用流式读取器发送数据到指定节点 参数: - protocol: protocols.ID 协议ID - genre: string 消息类型 - receiver: peer.ID 目标节点ID - reader: io.Reader 数据读取器 返回值: - *streams.ResponseMessage: 响应消息 - error: 如果发送过程中发生错误，返回相应的错误信息.

# Variables

StreamMutex 流互斥锁.