splithttp

type DefaultDialerClient struct {
	// contains filtered or unexported fields
}

type DialerClient interface {
	IsClosed() bool

	// ctx, url, body, uploadOnly
	OpenStream(context.Context, string, io.Reader, bool) (io.ReadCloser, net.Addr, net.Addr, error)

	// ctx, url, body, contentLength
	PostPacket(context.Context, string, io.Reader, int64) error
}

type DownConfig = xhpb.DownConfig

type DownConfig_Reality = xhpb.DownConfig_Reality

type DownConfig_Tls = xhpb.DownConfig_Tls

type FakePacketConn struct {
	net.Conn
}

type H1Conn struct {
	UnreadedResponsesCount int
	RespBufReader          *bufio.Reader
	net.Conn
}

type Listener struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Packet struct {
	Reader  io.ReadCloser
	Payload []byte
	Seq     uint64
}

type RangeConfig = xhpb.RangeConfig

type RangeConfig_builder = xhpb.RangeConfig_builder

type SplitHttpConfig = xhpb.SplitHttpConfig

type SplitHttpConfig_builder = xhpb.SplitHttpConfig_builder

type WaitReadCloser struct {
	Wait chan struct{}
	io.ReadCloser
}

type XhttpDialer struct {
	// contains filtered or unexported fields
}

type XmuxClient struct {
	XmuxConn  XmuxConn
	OpenUsage atomic.Int32

	LeftRequests atomic.Int32
	UnreusableAt time.Time
	// contains filtered or unexported fields
}

type XmuxConfig = xhpb.XmuxConfig

type XmuxConfig_builder = xhpb.XmuxConfig_builder

type XmuxConn interface {
	IsClosed() bool
}

type XmuxManager struct {
	// contains filtered or unexported fields
}