اگه از کتابخونه خوشتون اومد، یه ستاره (🌟) توی گیت‌هاب بدین که کلی دلگرمی می‌ده!

https://github.com/Ja7ad/otp

// UnsafeGetChannel provides direct read access to the underlying channel.
// WARNING: Bypasses all pipeline safeguards.
//
// Returns:
//   - The underlying receive channel
func (p *pipeline[T]) UnsafeGetChannel() <-chan T {
  return p.ch
}

func (p *pipeline[T]) Receive(ctx context.Context) <-chan T {
    out := make(chan T)
    go func() {
        defer close(out)
        for {
            select {
            case <-ctx.Done():
                return
            case item, ok := <-p.ch:
                if !ok {
                    return
                }
                out <- item
            }
        }
    }()
    return out
}

yay -S gofarsi-bin

@alefhepe

در ضمن مشارکت در کتاب آزاد است و جای تجربیات شما خالی است اگر مایل بودین می توانید تجربیات خود را در کتاب به اشتراک بزارید.

https://github.com/GoFarsi/book/blob/main/COUNTRIBUTING.md