stream

Documentation

Index

• func NewClientConn(parent net.Conn, connID conntypes.ConnID) conntypes.StreamReadWriteCloser
• func NewCtx(ctx context.Context, cancel context.CancelFunc, ...) conntypes.StreamReadWriteCloser
• func NewFakeTLS(socket conntypes.StreamReadWriteCloser) conntypes.StreamReadWriteCloser
• func NewMiddleProxyCipher(parent conntypes.StreamReadWriteCloser, req *rpc.NonceRequest, ...) conntypes.StreamReadWriteCloser
• func NewObfuscated2(socket conntypes.StreamReadWriteCloser, encryptor, decryptor cipher.Stream) conntypes.StreamReadWriteCloser
• func NewTelegramConn(dc conntypes.DC, parent net.Conn) conntypes.StreamReadWriteCloser
• func NewTelegramStats(dc conntypes.DC, parent conntypes.StreamReadWriteCloser) conntypes.StreamReadWriteCloser
• func NewTimeout(parent conntypes.StreamReadWriteCloser) conntypes.StreamReadWriteCloser
• func NewTrafficStats(parent conntypes.StreamReadWriteCloser) conntypes.StreamReadWriteCloser
• type ReadWriteCloseRewinder
  • func NewRewind(parent conntypes.StreamReadWriteCloser) ReadWriteCloseRewinder

Functions

func NewClientConn

func NewClientConn(parent net.Conn, connID conntypes.ConnID) conntypes.StreamReadWriteCloser

func NewCtx

func NewCtx(ctx context.Context,
	cancel context.CancelFunc,
	parent conntypes.StreamReadWriteCloser,
) conntypes.StreamReadWriteCloser

func NewFakeTLS

func NewFakeTLS(socket conntypes.StreamReadWriteCloser) conntypes.StreamReadWriteCloser

func NewMiddleProxyCipher

func NewMiddleProxyCipher(parent conntypes.StreamReadWriteCloser,
	req *rpc.NonceRequest,
	resp *rpc.NonceResponse,
	secret []byte,
) conntypes.StreamReadWriteCloser

func NewObfuscated2

func NewObfuscated2(socket conntypes.StreamReadWriteCloser,
	encryptor, decryptor cipher.Stream,
) conntypes.StreamReadWriteCloser

func NewTelegramConn

func NewTelegramConn(dc conntypes.DC, parent net.Conn) conntypes.StreamReadWriteCloser

func NewTelegramStats

func NewTelegramStats(dc conntypes.DC, parent conntypes.StreamReadWriteCloser) conntypes.StreamReadWriteCloser

func NewTimeout

func NewTimeout(parent conntypes.StreamReadWriteCloser) conntypes.StreamReadWriteCloser

func NewTrafficStats

func NewTrafficStats(parent conntypes.StreamReadWriteCloser) conntypes.StreamReadWriteCloser

Types

type ReadWriteCloseRewinder

type ReadWriteCloseRewinder interface {
	conntypes.StreamReadWriteCloser
	Rewind()
}

func NewRewind

func NewRewind(parent conntypes.StreamReadWriteCloser) ReadWriteCloseRewinder