utils

package

v0.6.0 Latest Latest Go to latest Published: Aug 11, 2025 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Atomic[T any] struct {
	// contains filtered or unexported fields
}

func (a *Atomic[T]) CompareAndSwap(old, new T) bool

func (a *Atomic[T]) Load() T

func (a *Atomic[T]) Store(value T)

func (a *Atomic[T]) Swap(new T) T

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

func NewAtomicTime(t time.Time) *AtomicTime

func (t *AtomicTime) Get() time.Time

func (t *AtomicTime) Set(new time.Time)

type QStream struct {
	Stream quic.Stream
}

QStream is a wrapper of quic.Stream that handles Close() in a way that makes more sense to us. By default, quic.Stream's Close() only closes the write side of the stream, not the read side. And if there is unread data, the stream is not really considered closed until either the data is drained or CancelRead() is called. References: - https://github.com/libp2p/go-libp2p/blob/master/p2p/transport/quic/stream.go - https://github.com/quic-go/quic-go/issues/3558 - https://github.com/quic-go/quic-go/issues/1599

func (s *QStream) CancelRead(code quic.StreamErrorCode)

func (s *QStream) CancelWrite(code quic.StreamErrorCode)

func (s *QStream) Close() error

func (s *QStream) Context() context.Context

func (s *QStream) Read(p []byte) (n int, err error)

func (s *QStream) SetDeadline(t time.Time) error

func (s *QStream) SetReadDeadline(t time.Time) error

func (s *QStream) SetWriteDeadline(t time.Time) error

func (s *QStream) StreamID() quic.StreamID

func (s *QStream) Write(p []byte) (n int, err error)