comm

type ConnectionManager interface {
	SendStream(data *pb.StreamMessage, successCallBack OnSuccess, errorCallBack OnError, connectionID string)

	Stop()

	Close(connectionID string)

	CreateStreamClientConn(connectionID string, ip string) error

	Size() int

	//Server on function
	Stream(stream pb.StreamService_StreamServer) error

	SetOnConnectHandler(onConnectionHandler OnConnectionHandler)

	Subscribe(name string, subfunc func(message msg.OutterMessage))
}

type ConnectionManagerImpl struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type OnConnectionHandler func(conn conn.Connection, peer pb.Peer)

type OnError func(error)

type OnSuccess func(interface{})