type github.com/gotd/td/internal/mtproto.Conn

45 uses

	github.com/gotd/td/internal/mtproto (current package)
		ack.go#L12: func (c *Conn) ackLoop(ctx context.Context) error {
		conn.go#L51: type Conn struct {
		conn.go#L117: func New(dialer Dialer, opt Options) *Conn {
		conn.go#L121: 	conn := &Conn{
		conn.go#L170: func (c *Conn) handleClose(ctx context.Context) error {
		conn.go#L186: func (c *Conn) Run(ctx context.Context, f func(ctx context.Context) error) error {
		connect.go#L15: func (c *Conn) connect(ctx context.Context) (rErr error) {
		connect.go#L59: func (c *Conn) createAuthKey(ctx context.Context) error {
		handle_ack.go#L11: func (c *Conn) handleAck(b *bin.Buffer) error {
		handle_bad_msg.go#L43: func (c *Conn) handleBadMsg(b *bin.Buffer) error {
		handle_container.go#L11: func (c *Conn) handleContainer(msgID int64, b *bin.Buffer) error {
		handle_container.go#L24: func (c *Conn) processContainerMessage(msgID int64, msg proto.Message) error {
		handle_future_salts.go#L13: func (c *Conn) handleFutureSalts(b *bin.Buffer) error {
		handle_gzip.go#L18: func (c *Conn) handleGZIP(msgID int64, b *bin.Buffer) error {
		handle_message.go#L12: func (c *Conn) handleMessage(msgID int64, b *bin.Buffer) error {
		handle_result.go#L13: func (c *Conn) handleResult(b *bin.Buffer) error {
		handle_session_created.go#L12: func (c *Conn) handleSessionCreated(b *bin.Buffer) error {
		message_id.go#L5: func (c *Conn) newMessageID() int64 {
		new_encrypted_msg.go#L12: func (c *Conn) newEncryptedMessage(id int64, seq int32, payload bin.Encoder, b *bin.Buffer) error {
		ping.go#L15: func (c *Conn) Ping(ctx context.Context) error {
		ping.go#L38: func (c *Conn) handlePong(b *bin.Buffer) error {
		ping.go#L56: func (c *Conn) pingDelayDisconnect(ctx context.Context, delay int) error {
		ping.go#L82: func (c *Conn) pong(pingID int64) chan struct{} {
		ping.go#L90: func (c *Conn) removePong(pingID int64) {
		ping.go#L96: func (c *Conn) pingLoop(ctx context.Context) error {
		read.go#L52: func (c *Conn) decryptMessage(b *bin.Buffer) (*crypto.EncryptedMessageData, error) {
		read.go#L73: func (c *Conn) consumeMessage(ctx context.Context, buf *bin.Buffer) error {
		read.go#L103: func (c *Conn) noUpdates(err error) bool {
		read.go#L114: func (c *Conn) handleAuthKeyNotFound(ctx context.Context) error {
		read.go#L133: func (c *Conn) readLoop(ctx context.Context) (err error) {
		rpc.go#L17: func (c *Conn) Invoke(ctx context.Context, input bin.Encoder, output bin.Decoder) error {
		rpc.go#L50: func (c *Conn) dropRPC(req rpc.Request) error {
		salt.go#L13: func (c *Conn) storeSalt(salt int64) {
		salt.go#L25: func (c *Conn) updateSalt() {
		salt.go#L36: func (c *Conn) getSalts(ctx context.Context) error {
		salt.go#L50: func (c *Conn) saltLoop(ctx context.Context) error {
		session.go#L13: func (c *Conn) session() Session {
		session.go#L26: func (c *Conn) newSessionID() error {
		write.go#L9: func (c *Conn) writeContentMessage(ctx context.Context, msgID int64, seqNo int32, message bin.Encoder) error {
		write.go#L13: func (c *Conn) writeServiceMessage(ctx context.Context, message bin.Encoder) error {
		write.go#L20: func (c *Conn) write(ctx context.Context, msgID int64, seqNo int32, message bin.Encoder) error {
		write.go#L40: func (c *Conn) nextMsgSeq(content bool) (msgID int64, seqNo int32) {
		zap.go#L26: func (c *Conn) logWithBuffer(b *bin.Buffer) *zap.Logger {
		zap.go#L30: func (c *Conn) logWithType(b *bin.Buffer) *zap.Logger {
		zap.go#L40: func (c *Conn) logWithTypeID(id uint32) *zap.Logger {