Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrUnknown = errors.New("unknown error")
)
Functions ¶
Types ¶
type StreamClient ¶
type StreamClient interface {
Close()
PublishMessage(chatId, userId, content string) error
GetSubscribeStream() pb.TransistorService_SubscribeClient
}
func NewStreamClient ¶
func NewStreamClient(pubaddr, subaddr string) (StreamClient, error)
Source Files
Click to show internal directories.
Click to hide internal directories.