type github.com/gotd/td/internal/rpc.Engine

15 uses

	github.com/gotd/td/internal/rpc (current package)
		ack.go#L8: func (e *Engine) NotifyAcks(ids []int64) {
		ack.go#L24: func (e *Engine) waitAck(id int64) chan struct{} {
		ack.go#L40: func (e *Engine) removeAck(id int64) {
		engine.go#L17: type Engine struct {
		engine.go#L39: func New(send Send, cfg Options) *Engine {
		engine.go#L48: 	return &Engine{
		engine.go#L75: func (e *Engine) Do(ctx context.Context, req Request) error {
		engine.go#L178: func (e *Engine) retryUntilAck(ctx context.Context, req Request) (sent bool, err error) {
		engine.go#L236: func (e *Engine) NotifyResult(msgID int64, b *bin.Buffer) error {
		engine.go#L249: func (e *Engine) NotifyError(msgID int64, rpcErr error) {
		engine.go#L262: func (e *Engine) isClosed() bool {
		engine.go#L269: func (e *Engine) Close() {
		engine.go#L278: func (e *Engine) ForceClose() {

	github.com/gotd/td/internal/mtproto
		conn.go#L57: 	rpc           *rpc.Engine
		options.go#L85: 	engine *rpc.Engine